Package xyz.cofe.trambda.tcp

Class ResultConsumer<Req extends Message,Res extends Message>

java.lang.Object

xyz.cofe.trambda.tcp.ResultConsumer<Req,Res>

public class ResultConsumer<Req extends Message,Res extends Message>
extends Object

Constructor Summary

Constructors

Constructor	Description
ResultConsumer(TcpProtocol proto, Req req, Map<Integer,Consumer<ErrMessage>> errorConsumers, Map<Integer,Consumer<Res>> responseConsumers)

Method Summary

Modifier and Type	Method	Description
ResultConsumer<Req,Res>	configure(Consumer<Req> reqConf)
Res	fetch()
ResultConsumer<Req,Res>	onFail(Consumer<ErrMessage> response)
ResultConsumer<Req,Res>	onFail(Consumer<ErrMessage> response, Consumer<xyz.cofe.fn.Tuple2<Consumer<ErrMessage>,Consumer<ErrMessage>>> changes)
ResultConsumer<Req,Res>	onSuccess(Consumer<Res> response)
ResultConsumer<Req,Res>	onSuccess(Consumer<Res> response, Consumer<xyz.cofe.fn.Tuple2<Consumer<Res>,Consumer<Res>>> changes)
void	send()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ResultConsumer

public ResultConsumer(TcpProtocol proto,
                      Req req,
                      Map<Integer,Consumer<ErrMessage>> errorConsumers,
                      Map<Integer,Consumer<Res>> responseConsumers)

Method Detail

onSuccess

public ResultConsumer<Req,Res> onSuccess(Consumer<Res> response)

onSuccess

public ResultConsumer<Req,Res> onSuccess(Consumer<Res> response,
                                               Consumer<xyz.cofe.fn.Tuple2<Consumer<Res>,Consumer<Res>>> changes)

onFail

public ResultConsumer<Req,Res> onFail(Consumer<ErrMessage> response)

onFail

public ResultConsumer<Req,Res> onFail(Consumer<ErrMessage> response,
                                            Consumer<xyz.cofe.fn.Tuple2<Consumer<ErrMessage>,Consumer<ErrMessage>>> changes)

configure

public ResultConsumer<Req,Res> configure(Consumer<Req> reqConf)

send

public void send()

fetch

public Res fetch()