ResultConsumer<Compile,CompileResult> |
TcpClient.compile(xyz.cofe.trambda.LambdaDump methodDef) |
Компиляция лямбды
|
ResultConsumer<Compile,CompileResult> |
TcpProtocol.compile(xyz.cofe.trambda.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) |
Добавляет подписчика на ошибочное выполнение.
|
protected 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) |
Добавляет подписчика на успешное выполнение запроса
|
protected 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) |
|