File tree Expand file tree Collapse file tree 1 file changed +6
-4
lines changed
packages/client/lib/client Expand file tree Collapse file tree 1 file changed +6
-4
lines changed Original file line number Diff line number Diff line change @@ -82,10 +82,12 @@ export default class RedisCommandsQueue {
82
82
83
83
if ( ! listeners . strings . size ) return ;
84
84
85
- // https://github.com/redis/redis/pull/7469
86
- // https://github.com/redis/redis/issues/7463
87
- const messageString = ( Array . isArray ( message ) ? message . map ( m => m . toString ( ) ) as any : message . toString ( ) ) ,
88
- channelString = pattern ? channel . toString ( ) : keyString ;
85
+ const channelString = pattern ? channel . toString ( ) : keyString ,
86
+ messageString = channelString === '__redis__:invalidate' ?
87
+ // https://github.com/redis/redis/pull/7469
88
+ // https://github.com/redis/redis/issues/7463
89
+ ( message === null ? null : ( message as any as Array < Buffer > ) . map ( x => x . toString ( ) ) ) as any :
90
+ message . toString ( ) ;
89
91
for ( const listener of listeners . strings ) {
90
92
listener ( messageString , channelString ) ;
91
93
}
You can’t perform that action at this time.
0 commit comments