Package | Description |
---|---|
org.jetlang.channels | |
org.jetlang.fibers |
Modifier and Type | Method and Description |
---|---|
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) |
Constructor and Description |
---|
AsyncRequest(Fiber target) |
BatchSubscriber(Fiber queue,
Callback<List<T>> receive,
Filter<T> filter,
int interval,
TimeUnit timeUnit) |
BatchSubscriber(Fiber queue,
Callback<List<T>> receive,
int interval,
TimeUnit timeUnit) |
KeyedBatchSubscriber(Fiber context,
Callback<Map<K,T>> target,
Filter<T> filter,
int flushIntervalInMs,
TimeUnit timeUnit,
Converter<T,K> keyResolver) |
KeyedBatchSubscriber(Fiber context,
Callback<Map<K,T>> target,
int flushIntervalInMs,
TimeUnit timeUnit,
Converter<T,K> keyResolver) |
LastSubscriber(Fiber context,
Callback<T> target,
Filter<T> filter,
int flushInterval,
TimeUnit timeUnit) |
LastSubscriber(Fiber context,
Callback<T> target,
int flushInterval,
TimeUnit timeUnit) |
RecyclingBatchSubscriber(Fiber queue,
Callback<MessageReader<T>> receive,
Filter<T> filter,
int interval,
TimeUnit timeUnit) |
RecyclingBatchSubscriber(Fiber queue,
Callback<MessageReader<T>> receive,
int interval,
TimeUnit timeUnit) |
Modifier and Type | Interface and Description |
---|---|
interface |
NioFiber |
Modifier and Type | Class and Description |
---|---|
class |
FiberStub
Provides a deterministic fiber implementation for testing.
|
class |
NioFiberImpl |
class |
ThreadFiber
Fiber implementation backed by a dedicated thread for execution.
|
Modifier and Type | Method and Description |
---|---|
Fiber |
PoolFiberFactory.create()
Create a new Fiber from this pool.
|
Fiber |
PoolFiberFactory.create(BatchExecutor batchExecutor)
Create a new Fiber from this pool that uses the supplied
Executor to execute commands |
Copyright © 2017. All Rights Reserved.