diff --git a/docs/stream/Interpersonal.md b/docs/stream/Interpersonal.md index 9e6b687..f3fbd5a 100644 --- a/docs/stream/Interpersonal.md +++ b/docs/stream/Interpersonal.md @@ -42,6 +42,7 @@ const consumer = new GroupConsumer({ }); await consumer.initialize(); +await consumer.init(); const readable = Readable.from(firstConsumer[Symbol.asyncIterator]()); readable.on("readable", async() => { diff --git a/docs/stream/Intrapersonal.md b/docs/stream/Intrapersonal.md index 0f6d61d..c0fff50 100644 --- a/docs/stream/Intrapersonal.md +++ b/docs/stream/Intrapersonal.md @@ -21,6 +21,7 @@ const consumer = new Intrapersonal({ }); await consumer.initialize(); +await consumer.init(); const readable = Readable.from(basicStream[Symbol.asyncIterator]()); ``` diff --git a/docs/stream/Stream.md b/docs/stream/Stream.md index c2c08bc..469545e 100644 --- a/docs/stream/Stream.md +++ b/docs/stream/Stream.md @@ -65,7 +65,7 @@ interface ConsumeOptions { ## 📚 Usage ```ts -import { Stream, RedisAdapter } from "@myunisoft/redis"; +import { Stream } from "@myunisoft/redis"; const redisStream = new Stream({ streamName: "my-stream-name", @@ -75,6 +75,7 @@ const redisStream = new Stream({ }); await redisStream.initialize(); +await redisStream.init(); ``` ## 📜 API