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.

All Implemented Interfaces:

PublisherSource<T>

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.

Nested classes/interfaces inherited from interface io.servicetalk.concurrent.PublisherSource

PublisherSource.Processor<T,R>, PublisherSource.Subscriber<T>, PublisherSource.Subscription

Method Summary

Modifier and Type	Method	Description
final Key	key()	Returns the key for this group.
final void	subscribe(PublisherSource.Subscriber<? super T> subscriber)	Subscribe for the result(s) of this PublisherSource.
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, firstAndTail, 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, 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

subscribe

public final void subscribe(PublisherSource.Subscriber<? super T> subscriber)

Description copied from interface: PublisherSource

Subscribe for the result(s) of this PublisherSource.

Specified by:

subscribe in interface PublisherSource<T>

Parameters:

subscriber - to subscribe for the result.