Commit 293adc6 1 parent 9b92e3e commit 293adc6 Copy full SHA for 293adc6
File tree 4 files changed +5
-5
lines changed
4 files changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -14,7 +14,7 @@ def initialize(handler)
14
14
@handler = handler
15
15
end
16
16
17
- def enqueue ( job )
17
+ def call ( job )
18
18
scheduled_at = Coder ::Time ( job [ :scheduled_at ] )
19
19
20
20
Async do
Original file line number Diff line number Diff line change @@ -46,7 +46,7 @@ def start
46
46
end
47
47
end
48
48
49
- def enqueue ( job )
49
+ def call ( job )
50
50
scheduled_at = Coder ::Time ( job [ :scheduled_at ] )
51
51
52
52
if scheduled_at
Original file line number Diff line number Diff line change 20
20
let ( :job ) { { data : "test job" } }
21
21
22
22
it "can schedule a job" do
23
- server . enqueue ( job )
23
+ server . call ( job )
24
24
25
25
expect ( buffer . pop ) . to be == job
26
26
end
Original file line number Diff line number Diff line change @@ -31,7 +31,7 @@ def before
31
31
let ( :job ) { { data : "test job" } }
32
32
33
33
it "can schedule a job and have it processed immediately" do
34
- server . enqueue ( job )
34
+ server . call ( job )
35
35
36
36
expect ( buffer . pop ) . to be == job
37
37
end
@@ -41,7 +41,7 @@ def before
41
41
now = Time . now
42
42
delayed_job = job . merge ( scheduled_at : now + 1 )
43
43
44
- server . enqueue ( delayed_job )
44
+ server . call ( delayed_job )
45
45
46
46
expect ( buffer . pop ) . to have_keys (
47
47
data : be == job [ :data ] ,
You can’t perform that action at this time.
0 commit comments