Skip to content

Commit 1830453

Browse files
cvgaviaoakarnokd
authored andcommitted
Update README.md (#6480)
fix issue #6479
1 parent ac84182 commit 1830453

File tree

1 file changed

+4
-6
lines changed

1 file changed

+4
-6
lines changed

README.md

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -258,12 +258,10 @@ Flowable.range(1, 10)
258258
```java
259259
Flowable<Inventory> inventorySource = warehouse.getInventoryAsync();
260260

261-
inventorySource.flatMap(inventoryItem ->
262-
erp.getDemandAsync(inventoryItem.getId())
263-
.map(demand
264-
-> System.out.println("Item " + inventoryItem.getName() + " has demand " + demand));
265-
)
266-
.subscribe();
261+
inventorySource
262+
.flatMap(inventoryItem -> erp.getDemandAsync(inventoryItem.getId())
263+
.map(demand -> "Item " + inventoryItem.getName() + " has demand " + demand))
264+
.subscribe(System.out::println);
267265
```
268266

269267
### Continuations

0 commit comments

Comments
 (0)