public class ReplyTracker<S extends Sink> extends Object implements Source, Sink
ReplyTracker(S reply, Map<Destination,S> cache)
void
send(Destination to, byte[] data)
setSink(Sink sink)
start()
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public ReplyTracker(S reply, Map<Destination,S> cache)
public void setSink(Sink sink)
setSink
Source
public void start()
start
public void send(Destination to, byte[] data)
send
Sink