public class ReadStreamAdapter<J,R> extends SingleOnSubscribeAdapter<R> implements Handler<J>
subRef| Constructor and Description |
|---|
ReadStreamAdapter(ReadStream<R> stream,
java.util.function.Function<J,R> adapter) |
| Modifier and Type | Method and Description |
|---|---|
void |
handle(J event)
Something has happened, so handle it.
|
void |
onSubscribed() |
void |
onUnsubscribed() |
call, fireComplete, fireError, fireNext, fireResult, getSubscriberpublic ReadStreamAdapter(ReadStream<R> stream, java.util.function.Function<J,R> adapter)
public void handle(J event)
Handlerpublic void onSubscribed()
onSubscribed in class SingleOnSubscribeAdapter<R>public void onUnsubscribed()
onUnsubscribed in class SingleOnSubscribeAdapter<R>Copyright © 2015. All rights reserved.