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