Package io.micronaut.core.async.processor

Class SingleThreadedBufferingProcessor<R,T>

java.lang.Object

io.micronaut.core.async.subscriber.SingleThreadedBufferingSubscriber<R>

io.micronaut.core.async.processor.SingleThreadedBufferingProcessor<R,T>

Type Parameters:

T - The argument type

R - The message type

All Implemented Interfaces:

Completable, Emitter<R>, Processor<R,T>, Publisher<T>, Subscriber<R>

Direct Known Subclasses:

JacksonCoreProcessor, JacksonProcessor

public abstract class SingleThreadedBufferingProcessor<R,T>
extends SingleThreadedBufferingSubscriber<R>
implements Processor<R,T>

A Reactive streams Processor designed to be used within a single thread and manage back pressure state.

This processor only supports a single Subscriber

Since:

1.0

Author:

Graeme Rocher

Nested Class Summary

Nested classes/interfaces inherited from class io.micronaut.core.async.subscriber.SingleThreadedBufferingSubscriber

SingleThreadedBufferingSubscriber.BackPressureState, SingleThreadedBufferingSubscriber.DownstreamSubscription

Field Summary

Fields inherited from class io.micronaut.core.async.subscriber.SingleThreadedBufferingSubscriber

upstreamBuffer, upstreamDemand, upstreamState, upstreamSubscription

Constructor Summary

Constructors

Constructor	Description
SingleThreadedBufferingProcessor()

Method Summary

Modifier and Type	Method	Description
protected Optional<Subscriber<? super T>>	currentDownstreamSubscriber()	Resolve the current Subscriber.
protected void	doOnComplete()	Implement Subscriber.onComplete().
protected void	doOnError(Throwable t)	Implement Subscriber.onError(Throwable).
protected void	doOnNext(R message)	Implement Subscriber.onNext(Object).
protected void	doOnSubscribe(Subscription subscription)	Implement Subscriber.onSubscribe(Subscription).
protected Subscriber<? super T>	getDownstreamSubscriber()	Resolve the current Subscriber.
protected abstract void	onUpstreamMessage(R message)	Called when an message is received from the upstream Subscriber.
void	subscribe(Subscriber<? super T> downstreamSubscriber)
protected void	subscribeDownstream(Subscriber<? super T> downstreamSubscriber)

Methods inherited from class io.micronaut.core.async.subscriber.SingleThreadedBufferingSubscriber

newDownstreamSubscription, onComplete, onError, onNext, onSubscribe, provideDownstreamSubscription

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.reactivestreams.Subscriber

onComplete, onError, onNext, onSubscribe

Constructor Details

SingleThreadedBufferingProcessor

public SingleThreadedBufferingProcessor()

Method Details

subscribe

public void subscribe(Subscriber<? super T> downstreamSubscriber)

Specified by:

subscribe in interface Publisher<R>

doOnComplete

protected void doOnComplete()

Description copied from class: SingleThreadedBufferingSubscriber

Implement Subscriber.onComplete().

Specified by:

doOnComplete in class SingleThreadedBufferingSubscriber<R>

doOnNext

protected void doOnNext(R message)

Description copied from class: SingleThreadedBufferingSubscriber

Implement Subscriber.onNext(Object).

Specified by:

doOnNext in class SingleThreadedBufferingSubscriber<R>

Parameters:

message - The message

doOnSubscribe

protected void doOnSubscribe(Subscription subscription)

Description copied from class: SingleThreadedBufferingSubscriber

Implement Subscriber.onSubscribe(Subscription).

Specified by:

doOnSubscribe in class SingleThreadedBufferingSubscriber<R>

Parameters:

subscription - The subscription

doOnError

protected void doOnError(Throwable t)

Description copied from class: SingleThreadedBufferingSubscriber

Implement Subscriber.onError(Throwable).

Specified by:

doOnError in class SingleThreadedBufferingSubscriber<R>

Parameters:

t - The throwable

subscribeDownstream

protected void subscribeDownstream(Subscriber<? super T> downstreamSubscriber)

Parameters:

downstreamSubscriber - The downstream subscriber

onUpstreamMessage

protected abstract void onUpstreamMessage(R message)

Called when an message is received from the upstream Subscriber.

Parameters:

message - The message

currentDownstreamSubscriber

protected Optional<Subscriber<? super T>> currentDownstreamSubscriber()

Resolve the current Subscriber.

Returns:

An Optional of the subscriber

getDownstreamSubscriber

protected Subscriber<? super T> getDownstreamSubscriber()

Resolve the current Subscriber.

Returns:

An Optional of the subscriber

Throws:

IllegalStateException - If no Subscriber is present