Package | Description |
---|---|
org.jetlang.channels | |
org.jetlang.fibers |
Modifier and Type | Interface and Description |
---|---|
interface |
Subscribable<T>
Interface to subscribe to events on producing thread(s).
|
Modifier and Type | Class and Description |
---|---|
class |
BaseSubscription<T>
Base implementation for all producer thread subscriptions.
|
class |
BatchSubscriber<T>
Batches events for the consuming thread.
|
class |
ChannelSubscription<T>
Subscription for events on a channel.
|
class |
KeyedBatchSubscriber<K,T>
Channel subscription that drops duplicates based upon a key.
|
class |
LastSubscriber<T>
Subscribes to last event received on the channel.
|
class |
RecyclingBatchSubscriber<T>
Batches events for the consuming thread.
|
Modifier and Type | Method and Description |
---|---|
void |
SubscriberList.add(Callback<T> cb) |
Disposable |
MemoryRequestChannel.publish(DisposingExecutor target,
R request,
Callback<V> reply) |
Disposable |
RequestChannel.publish(DisposingExecutor fiber,
R request,
Callback<V> reply) |
Disposable |
AsyncRequest.publish(RequestChannel<R,V> channel,
R req,
Callback<List<V>> onResponse) |
boolean |
SubscriberList.remove(Callback<T> cb) |
AsyncRequest<R,V> |
AsyncRequest.setTimeout(Callback<List<V>> onTimeout,
long time,
TimeUnit unit) |
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 |
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) |
Disposable |
RequestChannel.subscribe(DisposingExecutor fiber,
Callback<Request<R,V>> onRequest,
Callback<SessionClosed<R>> onRequestEnd) |
Disposable |
MemoryChannel.subscribe(DisposingExecutor queue,
Callback<T> onReceive) |
Disposable |
Subscriber.subscribe(DisposingExecutor executor,
Callback<T> receive)
Subscribe to receive messages produced by this subscriber
|
Disposable |
CompositeChannel.subscribe(DisposingExecutor executor,
Callback<T> receive) |
Disposable |
MemoryChannel.subscribeOnProducerThread(DisposingExecutor queue,
Callback<T> callbackOnQueue) |
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 |
---|
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) |
ChannelSubscription(DisposingExecutor queue,
Callback<T> receiveMethod) |
ChannelSubscription(DisposingExecutor fiber,
Callback<T> receiveMethod,
Filter<T> filter) |
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 | Method and Description |
---|---|
void |
NioFiber.execute(Callback<NioControls> asyncWrite) |
void |
NioFiberImpl.execute(Callback<NioControls> asyncWrite) |
Copyright © 2017. All Rights Reserved.