|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Subscribable | |
---|---|
org.jetlang.channels |
Uses of Subscribable in org.jetlang.channels |
---|
Classes in org.jetlang.channels that implement Subscribable | |
---|---|
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. |
Methods in org.jetlang.channels with parameters of type Subscribable | |
---|---|
Disposable |
Subscriber.subscribe(Subscribable<T> sub)
|
Disposable |
MemoryChannel.subscribe(Subscribable<T> sub)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |