public class MemoryRequestChannel<R,V> extends Object implements RequestChannel<R,V>
Constructor and Description |
---|
MemoryRequestChannel() |
Modifier and Type | Method and Description |
---|---|
Disposable |
publish(DisposingExecutor target,
R request,
Callback<V> reply) |
Disposable |
subscribe(DisposingExecutor fiber,
Callback<Request<R,V>> onRequest) |
Disposable |
subscribe(DisposingExecutor fiber,
Callback<Request<R,V>> onRequest,
Callback<SessionClosed<R>> onRequestEnd) |
public Disposable subscribe(DisposingExecutor fiber, Callback<Request<R,V>> onRequest)
subscribe
in interface RequestChannel<R,V>
public Disposable subscribe(DisposingExecutor fiber, Callback<Request<R,V>> onRequest, Callback<SessionClosed<R>> onRequestEnd)
subscribe
in interface RequestChannel<R,V>
public Disposable publish(DisposingExecutor target, R request, Callback<V> reply)
publish
in interface RequestChannel<R,V>
Copyright © 2017. All Rights Reserved.