Package io.servicetalk.concurrent.api
Class GroupedPublisher<Key,T>
- java.lang.Object
-
- io.servicetalk.concurrent.api.Publisher<T>
-
- io.servicetalk.concurrent.api.GroupedPublisher<Key,T>
-
- Type Parameters:
Key
- Key for the group. If this is of typeGroupedPublisher.QueueSizeProvider
new keys will use the value provided byGroupedPublisher.QueueSizeProvider.calculateMaxQueueSize(int)
to determine the maximum queue size for this group.T
- Items emitted by thisPublisher
.
public abstract class GroupedPublisher<Key,T> extends Publisher<T>
A group as emitted byPublisher.groupBy(Function, int)
or its variants.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static interface
GroupedPublisher.QueueSizeProvider
Provide the maximum queue size to use for a particularGroupedPublisher
key.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Key
key()
Returns the key for this group.java.lang.String
toString()
-
Methods inherited from class io.servicetalk.concurrent.api.Publisher
afterCancel, afterFinally, afterFinally, afterOnComplete, afterOnError, afterOnNext, afterOnSubscribe, afterRequest, afterSubscriber, afterSubscription, beforeCancel, beforeFinally, beforeFinally, beforeOnComplete, beforeOnError, beforeOnNext, beforeOnSubscribe, beforeRequest, beforeSubscriber, beforeSubscription, buffer, collect, completableOrError, concat, concat, concat, defer, empty, failed, filter, firstOrElse, firstOrError, flatMapCompletable, flatMapCompletable, flatMapCompletableDelayError, flatMapCompletableDelayError, flatMapCompletableDelayError, flatMapConcatIterable, flatMapMerge, flatMapMerge, flatMapMergeDelayError, flatMapMergeDelayError, flatMapMergeDelayError, flatMapMergeSingle, flatMapMergeSingle, flatMapMergeSingleDelayError, flatMapMergeSingleDelayError, flatMapMergeSingleDelayError, forEach, from, from, fromBlockingIterable, fromInputStream, fromIterable, groupBy, groupBy, groupToMany, groupToMany, handleSubscribe, idleTimeout, idleTimeout, idleTimeout, idleTimeout, ignoreElements, liftAsync, liftSync, liftSyncToSingle, map, multicastToExactly, multicastToExactly, never, publishAndSubscribeOn, publishAndSubscribeOnOverride, publishOn, publishOnOverride, range, range, recoverWith, repeat, repeatWhen, retry, retryWhen, scanWith, scanWith, subscribeInternal, subscribeOn, subscribeOnOverride, subscribeShareContext, takeAtMost, takeUntil, takeWhile, toCompletionStage, toCompletionStage, toFuture, toFuture, toInputStream, toInputStream, toIterable, toIterable, whenCancel, whenFinally, whenFinally, whenOnComplete, whenOnError, whenOnNext, whenOnSubscribe, whenRequest, whenSubscriber, whenSubscription
-
-
-
-
Method Detail
-
key
public final Key key()
Returns the key for this group.- Returns:
- Key for this group.
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-