public interface RequestChannel<R,V>
Modifier and Type | Method and Description |
---|---|
Disposable |
publish(DisposingExecutor fiber,
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) |
Disposable subscribe(DisposingExecutor fiber, Callback<Request<R,V>> onRequest)
Disposable publish(DisposingExecutor fiber, R request, Callback<V> reply)
Disposable subscribe(DisposingExecutor fiber, Callback<Request<R,V>> onRequest, Callback<SessionClosed<R>> onRequestEnd)
Copyright © 2017. All Rights Reserved.