Package | Description |
---|---|
reactor.rx |
Streams are reactive components derived from Reactive Extensions and implementing Reactive Streams specification.
|
Modifier and Type | Method and Description |
---|---|
<K> Stream<GroupedStream<K,O>> |
Stream.groupBy(Function<? super O,? extends K> keyMapper)
Re-route incoming values into a dynamically created
Stream for each unique key evaluated by the
{param keyMapper}. |
Stream<GroupedStream<Integer,O>> |
Stream.partition()
Re-route incoming values into a dynamically created
Stream for each unique key evaluated by the
{param keyMapper}. |
Stream<GroupedStream<Integer,O>> |
Stream.partition(int buckets)
Re-route incoming values into a dynamically created
Stream for each unique key evaluated by the
{param keyMapper}. |
Copyright © 2017. All rights reserved.