@@ -44,15 +44,37 @@ The current version is compatible with both:
44
44
45
45
## How to use
46
46
47
+ Installation:
48
+
49
+ ```
50
+ npm i @socket.io/redis-emitter redis
51
+ ```
52
+
47
53
### CommonJS
48
54
49
- Installation: ` npm i @socket.io/redis-emitter redis `
55
+ ``` js
56
+ const { Emitter } = require (" @socket.io/redis-emitter" );
57
+ const { createClient } = require (" redis" ); // not included, needs to be explicitly installed
58
+
59
+ const redisClient = createClient ();
60
+
61
+ redisClient .connect ().then (() => {
62
+ const io = new Emitter (redisClient);
63
+
64
+ setInterval (() => {
65
+ io .emit (" time" , new Date );
66
+ }, 5000 );
67
+ })
68
+ ```
69
+
70
+ With ` redis@3 ` , calling ` connect() ` is not needed:
50
71
51
72
``` js
52
73
const { Emitter } = require (" @socket.io/redis-emitter" );
53
74
const { createClient } = require (" redis" ); // not included, needs to be explicitly installed
54
75
55
76
const redisClient = createClient ();
77
+
56
78
const io = new Emitter (redisClient);
57
79
58
80
setInterval (() => {
@@ -62,18 +84,19 @@ setInterval(() => {
62
84
63
85
### TypeScript
64
86
65
- Installation: ` npm i @socket.io/redis-emitter redis @types/redis `
66
-
67
87
``` ts
68
88
import { Emitter } from " @socket.io/redis-emitter" ;
69
89
import { createClient } from " redis" ;
70
90
71
91
const redisClient = createClient ();
72
- const io = new Emitter (redisClient );
73
92
74
- setInterval (() => {
75
- io .emit (" time" , new Date );
76
- }, 5000 );
93
+ redisClient .connect ().then (() => {
94
+ const io = new Emitter (redisClient );
95
+
96
+ setInterval (() => {
97
+ io .emit (" time" , new Date );
98
+ }, 5000 );
99
+ });
77
100
```
78
101
79
102
With typed events:
@@ -87,9 +110,12 @@ interface Events {
87
110
}
88
111
89
112
const redisClient = createClient ();
90
- const io = new Emitter <Events >(redisClient );
91
113
92
- io .emit (" basicEmit" , 1 , " 2" , [3 ]);
114
+ redisClient .connect ().then (() => {
115
+ const io = new Emitter <Events >(redisClient );
116
+
117
+ io .emit (" basicEmit" , 1 , " 2" , [3 ]);
118
+ });
93
119
```
94
120
95
121
## Emit cheatsheet
0 commit comments