We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 0fada40 commit f373642Copy full SHA for f373642
content/websockets/adapter.md
@@ -44,11 +44,14 @@ import { createClient } from 'redis';
44
const io = new Server();
45
const pubClient = createClient({ url: `redis://localhost:6379` });
46
const subClient = pubClient.duplicate();
47
-const redisAdapter = io.adapter(createAdapter(pubClient, subClient));
+
48
+pubClient.connect();
49
+subClient.connect();
50
51
export class RedisIoAdapter extends IoAdapter {
52
createIOServer(port: number, options?: ServerOptions): any {
53
const server = super.createIOServer(port, options);
- server.adapter(redisAdapter);
54
+ server.adapter(createAdapter(pubClient, subClient));
55
return server;
56
}
57
0 commit comments