io.servicetalk.concurrent.api.internal

Class SpScPublisherProcessor<T>

java.lang.Object

io.servicetalk.concurrent.api.Publisher<T>

io.servicetalk.concurrent.api.internal.SubscribablePublisher<T>

io.servicetalk.concurrent.api.internal.SpScPublisherProcessor<T>

Type Parameters:

T - The type of Publisher.

All Implemented Interfaces:

PublisherSource<T>

public final class SpScPublisherProcessor<T>
extends SubscribablePublisher<T>

A Publisher that allows for signals to be directly injected via sendOnNext(Object), sendOnComplete(), and sendOnError(Throwable). The threading restrictions for this class are:

• SingleProducer meaning only a single thread is allowed to interact with sendOnNext(Object), sendOnComplete(), and sendOnError(Throwable) methods.
• SingleConsumer meaning only a single PublisherSource.Subscriber is supported. Other operators can be used to add support for multiple PublisherSource.Subscribers if necessary.

Nested Class Summary

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

PublisherSource.Subscriber<T>, PublisherSource.Subscription

Constructor Summary

Constructors

Constructor and Description
SpScPublisherProcessor(int maxOnNextQueueSize) Create a new instance.

Method Summary

Modifier and Type	Method and Description
protected void	handleSubscribe(PublisherSource.Subscriber<? super T> s) Handles a subscriber to this Publisher.
void	sendOnComplete() Send an PublisherSource.Subscriber#onComplete() signal to the subscriber of this Publisher.
void	sendOnError(java.lang.Throwable t) Send an PublisherSource.Subscriber#onError(Throwable) signal to the subscriber of this Publisher.
void	sendOnNext(T t) Send an PublisherSource.Subscriber#onNext(Object) signal to the subscriber of this Publisher.

Methods inherited from class io.servicetalk.concurrent.api.internal.SubscribablePublisher

subscribe

Methods inherited from class io.servicetalk.concurrent.api.Publisher

afterCancel, afterFinally, afterOnComplete, afterOnError, afterOnNext, afterOnSubscribe, afterRequest, afterSubscriber, afterSubscription, beforeCancel, beforeFinally, beforeOnComplete, beforeOnError, beforeOnNext, beforeOnSubscribe, beforeRequest, beforeSubscriber, beforeSubscription, collect, concat, concat, concat, defer, empty, failed, filter, firstOrElse, firstOrError, flatMapCompletable, flatMapCompletable, flatMapCompletableDelayError, flatMapCompletableDelayError, flatMapConcatIterable, flatMapMergeSingle, flatMapMergeSingle, flatMapMergeSingleDelayError, flatMapMergeSingleDelayError, forEach, from, from, fromBlockingIterable, fromInputStream, fromIterable, groupBy, groupBy, groupToMany, groupToMany, idleTimeout, idleTimeout, idleTimeout, idleTimeout, ignoreElements, liftAsync, liftSync, liftSyncToSingle, map, multicastToExactly, multicastToExactly, never, publishAndSubscribeOn, publishAndSubscribeOnOverride, publishOn, publishOnOverride, recoverWith, repeat, repeatWhen, retry, retryWhen, subscribeInternal, subscribeOn, subscribeOnOverride, subscribeShareContext, takeAtMost, takeUntil, takeWhile, toCompletionStage, toCompletionStage, toFuture, toFuture, toInputStream, toInputStream, toIterable, toIterable, whenCancel, whenFinally, whenOnComplete, whenOnError, whenOnNext, whenOnSubscribe, whenRequest

Methods inherited from class java.lang.Object

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

Constructor Detail

SpScPublisherProcessor

public SpScPublisherProcessor(int maxOnNextQueueSize)

Create a new instance.

Parameters:

maxOnNextQueueSize - The maximum amount of PublisherSource.Subscriber#onNext(Object) signals that can be queued from sendOnNext(Object).

Method Detail

handleSubscribe

protected void handleSubscribe(PublisherSource.Subscriber<? super T> s)

Description copied from class: Publisher

Handles a subscriber to this Publisher.

Specified by:

handleSubscribe in class Publisher<T>

Parameters:

s - the subscriber.

sendOnNext

public void sendOnNext(@Nullable
                       T t)

Send an PublisherSource.Subscriber#onNext(Object) signal to the subscriber of this Publisher.

Parameters:

t - The signals for PublisherSource.Subscriber#onNext(Object).

Throws:

QueueFullException - if the queue of signals would exceed the maximum size.

sendOnError

public void sendOnError(java.lang.Throwable t)

Send an PublisherSource.Subscriber#onError(Throwable) signal to the subscriber of this Publisher.

Parameters:

t - The signals for PublisherSource.Subscriber#onError(Throwable).

sendOnComplete

public void sendOnComplete()

Send an PublisherSource.Subscriber#onComplete() signal to the subscriber of this Publisher.