@@ -26,65 +26,65 @@ module.exports = RedisPubSub;
26
26
27
27
RedisPubSub . prototype = Object . create ( PubSub . prototype ) ;
28
28
29
- RedisPubSub . prototype . close = function ( callback ) {
29
+ RedisPubSub . prototype . close = function ( callback ) {
30
30
if ( ! callback ) {
31
- callback = function ( err ) {
31
+ callback = function ( err ) {
32
32
if ( err ) throw err ;
33
33
} ;
34
34
}
35
35
var pubsub = this ;
36
- PubSub . prototype . close . call ( this , function ( err ) {
36
+ PubSub . prototype . close . call ( this , function ( err ) {
37
37
if ( err ) return callback ( err ) ;
38
- pubsub . _close ( ) . then ( function ( ) {
38
+ pubsub . _close ( ) . then ( function ( ) {
39
39
callback ( ) ;
40
40
} , callback ) ;
41
41
} ) ;
42
42
} ;
43
43
44
- RedisPubSub . prototype . _close = function ( ) {
44
+ RedisPubSub . prototype . _close = function ( ) {
45
45
var pubsub = this ;
46
46
47
- if ( ! this . _closing ) {
47
+ if ( ! this . _closing ) {
48
48
this . _closing = this . _connect ( )
49
- . then ( function ( ) {
49
+ . then ( function ( ) {
50
50
return Promise . all ( [
51
51
close ( pubsub . client ) ,
52
52
close ( pubsub . observer )
53
- ] )
53
+ ] ) ;
54
54
} ) ;
55
55
}
56
56
57
57
return this . _closing ;
58
58
} ;
59
59
60
- RedisPubSub . prototype . _subscribe = function ( channel , callback ) {
60
+ RedisPubSub . prototype . _subscribe = function ( channel , callback ) {
61
61
var pubsub = this ;
62
62
pubsub . observer
63
- . subscribe ( channel , function ( message ) {
63
+ . subscribe ( channel , function ( message ) {
64
64
var data = JSON . parse ( message ) ;
65
65
pubsub . _emit ( channel , data ) ;
66
66
} )
67
- . then ( function ( ) {
67
+ . then ( function ( ) {
68
68
callback ( ) ;
69
69
} , callback ) ;
70
70
} ;
71
71
72
- RedisPubSub . prototype . _unsubscribe = function ( channel , callback ) {
72
+ RedisPubSub . prototype . _unsubscribe = function ( channel , callback ) {
73
73
this . observer . unsubscribe ( channel )
74
- . then ( function ( ) {
74
+ . then ( function ( ) {
75
75
callback ( ) ;
76
76
} , callback ) ;
77
77
} ;
78
78
79
- RedisPubSub . prototype . _publish = function ( channels , data , callback ) {
79
+ RedisPubSub . prototype . _publish = function ( channels , data , callback ) {
80
80
var message = JSON . stringify ( data ) ;
81
81
var args = [ message ] . concat ( channels ) ;
82
- this . client . eval ( PUBLISH_SCRIPT , { arguments : args } ) . then ( function ( ) {
82
+ this . client . eval ( PUBLISH_SCRIPT , { arguments : args } ) . then ( function ( ) {
83
83
callback ( ) ;
84
84
} , callback ) ;
85
85
} ;
86
86
87
- RedisPubSub . prototype . _connect = function ( ) {
87
+ RedisPubSub . prototype . _connect = function ( ) {
88
88
this . _clientConnection = this . _clientConnection || connect ( this . client ) ;
89
89
this . _observerConnection = this . _observerConnection || connect ( this . observer ) ;
90
90
return Promise . all ( [
0 commit comments