SingleThreadedBufferingProcessor (micronaut 3.4.2 API)

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:

AbstractBufferingHttpContentProcessor, DefaultHttpContentProcessor, 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 and Description

SingleThreadedBufferingProcessor()

Constructors
Constructor and Description
`SingleThreadedBufferingProcessor()`

Method Summary

All Methods Instance Methods Abstract Methods Concrete Methods
Modifier and Type	Method and 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 Detail
  - SingleThreadedBufferingProcessor
```
public SingleThreadedBufferingProcessor()
```
- Method Detail
  - subscribe
```
public void subscribe(Subscriber<? super T> downstreamSubscriber)
```
    Specified by:
    
    subscribe in interface Publisher<T>
  - 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

Class SingleThreadedBufferingProcessor<R,T>

Nested Class Summary

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

Field Summary

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

Constructor Summary

Method Summary

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

Methods inherited from class java.lang.Object

Methods inherited from interface org.reactivestreams.Subscriber

Constructor Detail

SingleThreadedBufferingProcessor

Method Detail

subscribe

doOnComplete

doOnNext

doOnSubscribe

doOnError

subscribeDownstream

onUpstreamMessage

currentDownstreamSubscriber

getDownstreamSubscriber