Package | Description |
---|---|
org.jetlang.channels |
Modifier and Type | Class and Description |
---|---|
class |
MemoryRequestChannel<R,V>
User: mrettig
Date: Jan 31, 2009
Time: 10:42:42 AM
|
Modifier and Type | Method and Description |
---|---|
Disposable |
AsyncRequest.publish(RequestChannel<R,V> channel,
R req,
Callback<List<V>> onResponse) |
static <R,V> Disposable |
AsyncRequest.withOneReply(Fiber fiber,
RequestChannel<R,V> channel,
R req,
Callback<V> onReply) |
static <R,V> Disposable |
AsyncRequest.withOneReply(Fiber fiber,
RequestChannel<R,V> channel,
R req,
Callback<V> onReply,
long timeout,
TimeUnit unit,
Runnable onTimeout) |
Copyright © 2017. All Rights Reserved.