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 type GroupedPublisher.QueueSizeProvider new keys will use the value provided by GroupedPublisher.QueueSizeProvider.calculateMaxQueueSize(int) to determine the maximum queue size for this group.

T - Items emitted by this Publisher.

public abstract class GroupedPublisher<Key,T>
extends Publisher<T>

A group as emitted by Publisher.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 particular GroupedPublisher key.

Method Summary

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, from, from, fromBlockingIterable, fromInputStream, fromInputStream, fromIterable, groupBy, groupBy, groupToMany, groupToMany, handleSubscribe, idleTimeout, idleTimeout, idleTimeout, idleTimeout, ignoreElements, liftAsync, liftSync, liftSyncToSingle, map, multicastToExactly, multicastToExactly, never, onErrorComplete, onErrorComplete, onErrorComplete, onErrorMap, onErrorMap, onErrorMap, onErrorResume, onErrorResume, onErrorResume, onErrorReturn, onErrorReturn, onErrorReturn, publishAndSubscribeOn, publishAndSubscribeOnOverride, publishOn, publishOnOverride, range, range, recoverWith, repeat, repeatWhen, retry, retryWhen, scanWith, scanWith, scanWithLifetime, subscribeInternal, subscribeOn, subscribeOnOverride, subscribeShareContext, takeAtMost, takeUntil, takeWhile, timeout, timeout, timeout, timeout, timeoutTerminal, timeoutTerminal, timeoutTerminal, timeoutTerminal, toCompletionStage, toCompletionStage, toFuture, toFuture, toInputStream, toInputStream, toIterable, toIterable, whenCancel, whenFinally, whenFinally, whenOnComplete, whenOnError, whenOnNext, whenOnSubscribe, whenRequest, whenSubscriber, whenSubscription

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

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 class java.lang.Object