Skip to content

Commit 8e57466

Browse files
committed
Update README.md
1 parent ba82985 commit 8e57466

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

README.md

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -245,6 +245,13 @@ Note that above you don't need to worry about closing `entry.getInputStream()` b
245245
You must process the emissions of `ZippedEntry` synchronously (don't replace the `concatMap()` with a `flatMap(... .subscribeOn(Schedulers.computation())` for instance. This is because the `InputStream` of each `ZippedEntry` must be processed fullly (which could mean ignoring it of course) before moving on to the next one.
246246

247247

248+
Transformers.orderedMerge
249+
--------------------------
250+
To merge two streams in order (according to a `Comparator`):
251+
252+
```java
253+
source1.compose(Transformers.orderedMergeWith(source2, comparator));
254+
```
248255

249256
TestingHelper
250257
-----------------

0 commit comments

Comments
 (0)