public final class NbpOperatorWindowBoundarySelector<T,B,V> extends java.lang.Object implements NbpObservable.NbpOperator<NbpObservable<T>,T>
| Constructor and Description |
|---|
NbpOperatorWindowBoundarySelector(NbpObservable<B> open,
Function<? super B,? extends NbpObservable<V>> close,
int bufferSize) |
| Modifier and Type | Method and Description |
|---|---|
NbpObservable.NbpSubscriber<? super T> |
apply(NbpObservable.NbpSubscriber<? super NbpObservable<T>> t) |
public NbpOperatorWindowBoundarySelector(NbpObservable<B> open, Function<? super B,? extends NbpObservable<V>> close, int bufferSize)
public NbpObservable.NbpSubscriber<? super T> apply(NbpObservable.NbpSubscriber<? super NbpObservable<T>> t)
apply in interface Function<NbpObservable.NbpSubscriber<? super NbpObservable<T>>,NbpObservable.NbpSubscriber<? super T>>