File tree Expand file tree Collapse file tree 1 file changed +5
-5
lines changed
Expand file tree Collapse file tree 1 file changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -75,8 +75,8 @@ This makes it possible for a Duplex stream to return a value to the original emi
7575simply taking values coming from the pipeline and re-emitting them into the caller stream.
7676``` js
7777const stream = new Duplex ().pipe (
78- ... operators,
79- map (data => asReturnValue (data)),
78+ ... operators,
79+ map (data => asReturnValue (data)),
8080).reply ();
8181```
8282
@@ -88,7 +88,7 @@ Similar to RxJS `switchMap`. It emits the current value from the source stream a
8888
8989``` js
9090source .pipe (
91- switchInvoke (OTHER_TOPIC ),
91+ switchInvoke (OTHER_TOPIC ),
9292 map (rv => { // returned values
9393 })
9494);
@@ -99,7 +99,7 @@ Similar to RxJS `mergeMap`. It emits the current value from the source stream in
9999
100100``` js
101101source .pipe (
102- mergeInvoke (OTHER_TOPIC ),
102+ mergeInvoke (OTHER_TOPIC ),
103103 map (rv => { // returned values
104104 })
105105);
@@ -111,7 +111,7 @@ A fire-and-forget operator that simply emits the current value into the specifie
111111
112112``` js
113113source .pipe (
114- emit (OTHER_TOPIC )
114+ emit (OTHER_TOPIC )
115115);
116116```
117117
You can’t perform that action at this time.
0 commit comments