Commit 3f88876 1 parent 60c045c commit 3f88876 Copy full SHA for 3f88876
File tree 3 files changed +4
-1
lines changed
3 files changed +4
-1
lines changed Original file line number Diff line number Diff line change @@ -42,6 +42,7 @@ const consumer = new GroupConsumer({
42
42
});
43
43
44
44
await consumer .initialize ();
45
+ await consumer .init ();
45
46
46
47
const readable = Readable .from (firstConsumer [Symbol .asyncIterator ]());
47
48
readable .on (" readable" , async () => {
Original file line number Diff line number Diff line change @@ -21,6 +21,7 @@ const consumer = new Intrapersonal({
21
21
});
22
22
23
23
await consumer .initialize ();
24
+ await consumer .init ();
24
25
25
26
const readable = Readable .from (basicStream [Symbol .asyncIterator ]());
26
27
```
Original file line number Diff line number Diff line change @@ -65,7 +65,7 @@ interface ConsumeOptions {
65
65
## 📚 Usage
66
66
67
67
``` ts
68
- import { Stream , RedisAdapter } from " @myunisoft/redis" ;
68
+ import { Stream } from " @myunisoft/redis" ;
69
69
70
70
const redisStream = new Stream ({
71
71
streamName: " my-stream-name" ,
@@ -75,6 +75,7 @@ const redisStream = new Stream({
75
75
});
76
76
77
77
await redisStream .initialize ();
78
+ await redisStream .init ();
78
79
```
79
80
80
81
## 📜 API
You can’t perform that action at this time.
0 commit comments