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 |
execute() |
void |
handle(J event)
Something has happened, so handle it.
|
void |
onUnsubscribed() |
call, fireComplete, fireError, fireNext, fireResult, getSubscriber
public ReadStreamAdapter(ReadStream<R> stream, java.util.function.Function<J,R> adapter)
public void handle(J event)
Handler
public void execute()
execute
in class SingleOnSubscribeAdapter<R>
public void onUnsubscribed()
onUnsubscribed
in class SingleOnSubscribeAdapter<R>
Copyright © 2015. All Rights Reserved.