@@ -17,51 +17,32 @@ describe("publish/subscribe", function () {
17
17
var message = "test message" ;
18
18
19
19
beforeEach ( function ( done ) {
20
- var pubConnected ;
21
- var subConnected ;
20
+ var end = helper . callFuncAfter ( done , 2 ) ;
22
21
23
22
pub = redis . createClient . apply ( redis . createClient , args ) ;
24
23
sub = redis . createClient . apply ( redis . createClient , args ) ;
25
24
pub . once ( "connect" , function ( ) {
26
25
pub . flushdb ( function ( ) {
27
- pubConnected = true ;
28
- if ( subConnected ) {
29
- done ( ) ;
30
- }
26
+ end ( ) ;
31
27
} ) ;
32
28
} ) ;
33
29
sub . once ( "connect" , function ( ) {
34
- subConnected = true ;
35
- if ( pubConnected ) {
36
- done ( ) ;
37
- }
30
+ end ( ) ;
38
31
} ) ;
39
32
} ) ;
40
33
41
34
describe ( 'disable resubscribe' , function ( ) {
42
35
beforeEach ( function ( done ) {
43
- var pubConnected ;
44
- var subConnected ;
45
-
46
- pub = redis . createClient ( ) ;
36
+ sub . end ( false ) ;
47
37
sub = redis . createClient ( {
48
38
disable_resubscribing : true
49
39
} ) ;
50
- pub . once ( "connect" , function ( ) {
51
- pubConnected = true ;
52
- if ( subConnected ) {
53
- done ( ) ;
54
- }
55
- } ) ;
56
40
sub . once ( "connect" , function ( ) {
57
- subConnected = true ;
58
- if ( pubConnected ) {
59
- done ( ) ;
60
- }
41
+ done ( ) ;
61
42
} ) ;
62
43
} ) ;
63
44
64
- it ( 'does not fire subscribe events after reconnecting' , function ( done ) {
45
+ it . only ( 'does not fire subscribe events after reconnecting' , function ( done ) {
65
46
var a = false ;
66
47
sub . on ( "subscribe" , function ( chnl , count ) {
67
48
if ( chnl === channel2 ) {
@@ -75,11 +56,12 @@ describe("publish/subscribe", function () {
75
56
76
57
sub . on ( 'reconnecting' , function ( ) {
77
58
a = true ;
59
+ sub . on ( 'ready' , function ( ) {
60
+ setTimeout ( done , 250 ) ;
61
+ } ) ;
78
62
} ) ;
79
63
80
64
sub . subscribe ( channel , channel2 ) ;
81
-
82
- setTimeout ( done , 250 ) ;
83
65
} ) ;
84
66
} ) ;
85
67
0 commit comments