Package | Description |
---|---|
org.jetlang.channels |
Modifier and Type | Method and Description |
---|---|
Disposable |
MemoryRequestChannel.subscribe(DisposingExecutor fiber,
Callback<Request<R,V>> onRequest) |
Disposable |
RequestChannel.subscribe(DisposingExecutor fiber,
Callback<Request<R,V>> onRequest) |
Disposable |
MemoryRequestChannel.subscribe(DisposingExecutor fiber,
Callback<Request<R,V>> onRequest,
Callback<SessionClosed<R>> onRequestEnd) |
Disposable |
RequestChannel.subscribe(DisposingExecutor fiber,
Callback<Request<R,V>> onRequest,
Callback<SessionClosed<R>> onRequestEnd) |
Copyright © 2017. All Rights Reserved.