ResultConsumer<Compile,CompileResult> |
TcpClient.compile(LambdaDump methodDef) |
|
ResultConsumer<Compile,CompileResult> |
TcpProtocol.compile(LambdaDump methodDef) |
|
ResultConsumer<Req,Res> |
ResultConsumer.configure(Consumer<Req> reqConf) |
|
ResultConsumer<Execute,ExecuteResult> |
TcpClient.execute(CompileResult cres) |
|
ResultConsumer<Execute,ExecuteResult> |
TcpProtocol.execute(CompileResult cres) |
|
ResultConsumer<Req,Res> |
ResultConsumer.onFail(Consumer<ErrMessage> response) |
|
ResultConsumer<Req,Res> |
ResultConsumer.onFail(Consumer<ErrMessage> response,
Consumer<xyz.cofe.fn.Tuple2<Consumer<ErrMessage>,Consumer<ErrMessage>>> changes) |
|
ResultConsumer<Req,Res> |
ResultConsumer.onSuccess(Consumer<Res> response) |
|
ResultConsumer<Req,Res> |
ResultConsumer.onSuccess(Consumer<Res> response,
Consumer<xyz.cofe.fn.Tuple2<Consumer<Res>,Consumer<Res>>> changes) |
|
ResultConsumer<Subscribe,SubscribeResult> |
TcpClient.subscribe(String publisher,
Consumer<ServerEvent> listener) |
|
ResultConsumer<Subscribe,SubscribeResult> |
TcpClient.subscribe(Subscribe subscribe,
Consumer<ServerEvent> listener) |
|
ResultConsumer<Subscribe,SubscribeResult> |
TcpProtocol.subscribe(Subscribe subscribe) |
|
ResultConsumer<UnSubscribe,UnSubscribeResult> |
TcpClient.unsubscribe(String publisher) |
|
ResultConsumer<UnSubscribe,UnSubscribeResult> |
TcpClient.unsubscribe(UnSubscribe subscribe) |
|
ResultConsumer<UnSubscribe,UnSubscribeResult> |
TcpProtocol.unsubscribe(UnSubscribe subscribe) |
|