Package | Description |
---|---|
reactor.rx.action.aggregation | |
reactor.rx.action.combination | |
reactor.rx.action.transformation |
Modifier and Type | Method and Description |
---|---|
protected ReactiveSubscription<T> |
WindowShiftAction.createWindowStream() |
ReactiveSubscription<T> |
WindowAction.currentWindow() |
Modifier and Type | Class and Description |
---|---|
class |
FanInSubscription<O,E,X,SUBSCRIBER extends FanInAction.InnerSubscriber<O,E,X>> |
Modifier and Type | Method and Description |
---|---|
Map<K,ReactiveSubscription<T>> |
GroupByAction.groupByMap() |
Copyright © 2017. All rights reserved.