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 Channel
public io.reactivex.Observable<byte[]> inputStream()
inputStream
in interface Channel
public io.reactivex.Observable<byte[]> errorStream()
errorStream
in interface Channel
public void onConnectionLost(java.lang.Runnable onConnectionLost)
onConnectionLost
in interface Channel
Copyright © 2017–2018 Ocraft Project. All rights reserved.