1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
|
require File.expand_path('../spec_helper', __FILE__)
TEMP_FILE_PATH = "./test.txt"
INTERVAL = 0.010
class MyStatWatcher < Cool.io::StatWatcher
attr_accessor :accessed, :previous, :current
def initialize(path)
super path, INTERVAL
end
def on_change(previous, current)
self.accessed = true
self.previous = previous
self.current = current
end
end
def run_with_file_change(path)
reactor = Cool.io::Loop.new
sw = MyStatWatcher.new(path)
sw.attach(reactor)
tw = Cool.io::TimerWatcher.new(INTERVAL, true)
tw.on_timer do
reactor.stop if sw.accessed
write_file(path)
end
tw.attach(reactor)
reactor.run
tw.detach
sw.detach
sw
end
def write_file(path)
File.open(path, "w+") { |f| f.write(rand.to_s) }
end
def delete_file(path)
File.delete(TEMP_FILE_PATH)
end
describe Cool.io::StatWatcher do
let :watcher do
run_with_file_change(TEMP_FILE_PATH)
end
before :each do
write_file(TEMP_FILE_PATH)
end
after :each do
delete_file(TEMP_FILE_PATH)
end
it "fire on_change when the file it is watching is modified" do
expect(watcher.accessed).to eq(true)
end
it "should pass previous and current file stat info given a stat watcher" do
expect(watcher.previous.ino).to eq(watcher.current.ino)
end
it "should raise when the handler does not take 2 parameters" do
class MyStatWatcher < Cool.io::StatWatcher
remove_method :on_change
def on_change
end
end
expect { watcher.accessed }.to raise_error(ArgumentError)
end
end
|
