doc(./docs/stream/~): updated doc

MyUnisoft · Dec 19, 2024 · af14a44 · af14a44
1 parent 60c045c
commit af14a44
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 1 deletion.
diff --git 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
@@ -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
@@ -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
-Original file line number
+Diff line change
@@ Expand Up / @@ -21,6 +21,7 @@ const consumer = new Intrapersonal({ @@
     });
     await consumer.initialize();
+    await consumer.init();
     const readable = Readable.from(basicStream[Symbol.asyncIterator]());
     ```
@@ Expand Down @@