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.

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	Deprecated. Use Publisher.groupBy(Function, int) instead.

Method Summary

Modifier and Type	Method	Description
final Key	key()	Returns the key for this group.
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, cast, collect, completableOrError, concat, concat, concat, concatPropagateCancel, defer, distinct, empty, failed, filter, firstOrElse, firstOrError, flatMapCompletable, flatMapCompletable, flatMapCompletableDelayError, flatMapCompletableDelayError, flatMapCompletableDelayError, flatMapConcatIterable, flatMapConcatSingle, flatMapConcatSingle, flatMapConcatSingleDelayError, flatMapConcatSingleDelayError, flatMapMerge, flatMapMerge, flatMapMergeDelayError, flatMapMergeDelayError, flatMapMergeDelayError, flatMapMergeSingle, flatMapMergeSingle, flatMapMergeSingleDelayError, flatMapMergeSingleDelayError, flatMapMergeSingleDelayError, forEach, from, from, from, from, fromBlockingIterable, fromInputStream, fromInputStream, fromIterable, groupBy, groupBy, groupBy, groupToMany, groupToMany, handleSubscribe, ignoreElements, liftAsync, liftSync, liftSyncToSingle, map, merge, mergeAll, mergeAll, mergeAllDelayError, mergeAllDelayError, mergeDelayError, multicast, multicast, multicast, multicast, multicast, multicast, multicastToExactly, multicastToExactly, never, ofType, onCompleteError, onErrorComplete, onErrorComplete, onErrorComplete, onErrorMap, onErrorMap, onErrorMap, onErrorResume, onErrorResume, onErrorResume, onErrorReturn, onErrorReturn, onErrorReturn, publishOn, publishOn, range, range, repeat, repeatWhen, replay, replay, replay, replay, retry, retry, retryWhen, retryWhen, scanWith, scanWith, scanWithLifetime, scanWithLifetimeMapper, scanWithMapper, setContextOnSubscribe, shareContextOnSubscribe, skipWhile, subscribeInternal, subscribeOn, subscribeOn, switchMap, switchMapDelayError, switchMapDelayError, takeAtMost, takeUntil, takeWhile, timeout, timeout, timeout, timeout, timeoutDemand, timeoutDemand, timeoutDemand, timeoutDemand, timeoutTerminal, timeoutTerminal, timeoutTerminal, timeoutTerminal, toCompletionStage, toCompletionStage, toFuture, toFuture, toInputStream, toInputStream, toIterable, toIterable, validateOutstandingDemand, validateOutstandingDemand, 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 Details

key

public final Key key()

Returns the key for this group.

Returns:

Key for this group.

toString

public String toString()

Overrides:

toString in class Object