Package | Description |
---|---|
org.jetlang.channels | |
org.jetlang.core | |
org.jetlang.fibers |
Modifier and Type | Method and Description |
---|---|
DisposingExecutor |
BaseSubscription.getQueue() |
DisposingExecutor |
Subscribable.getQueue() |
Modifier and Type | Method and Description |
---|---|
Disposable |
MemoryRequestChannel.publish(DisposingExecutor target,
R request,
Callback<V> reply) |
Disposable |
RequestChannel.publish(DisposingExecutor fiber,
R request,
Callback<V> reply) |
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) |
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) |
Constructor and Description |
---|
BaseSubscription(DisposingExecutor fiber) |
BaseSubscription(DisposingExecutor fiber,
Filter<T> _filter) |
ChannelSubscription(DisposingExecutor queue,
Callback<T> receiveMethod) |
ChannelSubscription(DisposingExecutor fiber,
Callback<T> receiveMethod,
Filter<T> filter) |
Modifier and Type | Interface and Description |
---|---|
interface |
RunnableExecutor
Queues and executes events.
|
Modifier and Type | Class and Description |
---|---|
class |
RunnableExecutorImpl
Default implementation that queues and executes events.
|
class |
SynchronousDisposingExecutor
A synchronous execute typically used for testing.
|
Constructor and Description |
---|
SchedulerImpl(DisposingExecutor queue,
ScheduledExecutorService scheduler) |
Modifier and Type | Interface and Description |
---|---|
interface |
Fiber
Fibers provide event queueing, scheduling, and full pub/sub capabilities when combined with a
Channel . |
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.
|
Copyright © 2017. All Rights Reserved.