-
Notifications
You must be signed in to change notification settings - Fork 2
/
redis_spec.cr
96 lines (72 loc) · 2.25 KB
/
redis_spec.cr
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
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
require "../../spec_helper"
require "../../../src/onyx-eda/channel/redis"
class Onyx::EDA::Channel::Redis
struct TestEvent::A
include Onyx::EDA::Event
getter payload : String
def initialize(@payload : String)
end
end
struct TestEvent::B
include Onyx::EDA::Event
getter payload : Int32
def initialize(@payload : Int32)
end
end
describe self do
channel = self.new(ENV["REDIS_URL"], logger: Logger.new(STDOUT))
buffer = Hash(String, String | Int32).new
describe "subscription" do
it do
sub_a = channel.subscribe(TestEvent::A) do |event|
buffer["a"] = event.payload
end
sub_b = channel.subscribe(TestEvent::B) do |event|
buffer["b"] = event.payload
end
sub_c = channel.subscribe(TestEvent::B, payload: 42) do |event|
buffer["c"] = event.payload
end
sleep(0.25)
channel.emit(TestEvent::A.new("foo"), TestEvent::B.new(42))
sleep(0.25)
buffer["a"].should eq "foo"
buffer["b"].should eq 42
buffer["c"].should eq 42
buffer.clear
channel.emit(TestEvent::B.new(43))
sleep(0.25)
buffer["a"]?.should be_nil # A is not emitted
buffer["b"].should eq 43
buffer["c"]?.should be_nil # C doesn't match the filter
buffer.clear
sub_a.unsubscribe.should be_true
channel.unsubscribe(sub_b).should be_true
sub_c.unsubscribe.should be_true
end
end
describe "consumption" do
it do
sub_a = channel.subscribe(TestEvent::A, "foo") do |event|
buffer["a"] = event.payload
end
sub_b = channel.subscribe(TestEvent::B, "foo") do |event|
buffer["b"] = event.payload
end
sub_c = channel.subscribe(TestEvent::B, "bar") do |event|
buffer["c"] = event.payload
end
sleep(0.1)
channel.emit(TestEvent::A.new("foo"), TestEvent::B.new(42))
sleep(0.1)
buffer["a"].should eq "foo"
buffer["b"].should eq 42
buffer["c"].should eq 42
buffer.clear
sub_a.unsubscribe.should be_true
channel.unsubscribe(sub_b).should be_true
sub_c.unsubscribe.should be_true
end
end
end
end