| Modifier and Type | Method | Description |
|---|---|---|
void |
error(java.lang.Throwable error) |
|
io.reactivex.Observable<byte[]> |
errorStream() |
|
void |
input(byte[] inputBytes) |
|
io.reactivex.Observable<byte[]> |
inputStream() |
|
void |
onConnectionLost(java.lang.Runnable onConnectionLost) |
|
void |
output(byte[] outputBytes) |
|
io.reactivex.Observable<byte[]> |
outputStream() |
|
boolean |
ready() |
public io.reactivex.Observable<byte[]> outputStream()
outputStream in interface Channelpublic io.reactivex.Observable<byte[]> inputStream()
inputStream in interface Channelpublic io.reactivex.Observable<byte[]> errorStream()
errorStream in interface Channelpublic void onConnectionLost(java.lang.Runnable onConnectionLost)
onConnectionLost in interface ChannelCopyright © 2017–2018 Ocraft Project. All rights reserved.