File tree 2 files changed +8
-9
lines changed
2 files changed +8
-9
lines changed Original file line number Diff line number Diff line change 18
18
(swap! state conj msg))})
19
19
chans-msgs)}))
20
20
21
-
22
21
; ;
23
22
(t/deftest pubsub-test
24
23
(let [client (rq/create-client " redis://localhost:6379" )]
Original file line number Diff line number Diff line change 5
5
6
6
(t/deftest pattern->str-test
7
7
(t/testing " packing"
8
- [(t/is " my-queue" (utils/pack-pattern :none " my-queue" ))
9
- (t/is " rq:my-queue" (utils/pack-pattern :rq " my-queue" ))
10
- (t/is " rq:pubsub:my-queue" (utils/pack-pattern :pubsub " my-queue" ))
11
- (t/is " rq:pubsub:pending:my-queue" (utils/pack-pattern :pending " my-queue" ))])
8
+ [(t/is " my-queue" (utils/pack-pattern :none " my-queue" ))
9
+ (t/is " rq:my-queue" (utils/pack-pattern :rq " my-queue" ))
10
+ (t/is " rq:pubsub:my-queue" (utils/pack-pattern :pubsub " my-queue" ))
11
+ (t/is " rq:pubsub:pending:my-queue" (utils/pack-pattern :pending " my-queue" ))])
12
12
13
13
(t/testing " unpacking"
14
- [(t/is " my-queue" (utils/unpack-pattern :none " my-queue" ))
15
- (t/is " my-queue" (utils/unpack-pattern :rq " rq:my-queue" ))
16
- (t/is " my-queue" (utils/unpack-pattern :pubsub " rq:pubsub:my-queue" ))
17
- (t/is " my-queue" (utils/unpack-pattern :pending " rq:pubsub:pending:my-queue" ))]))
14
+ [(t/is " my-queue" (utils/unpack-pattern :none " my-queue" ))
15
+ (t/is " my-queue" (utils/unpack-pattern :rq " rq:my-queue" ))
16
+ (t/is " my-queue" (utils/unpack-pattern :pubsub " rq:pubsub:my-queue" ))
17
+ (t/is " my-queue" (utils/unpack-pattern :pending " rq:pubsub:pending:my-queue" ))]))
You can’t perform that action at this time.
0 commit comments