Package | Description |
---|---|
org.jetlang.channels |
Modifier and Type | Class and Description |
---|---|
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.
|
Copyright © 2017. All Rights Reserved.