SequentialSubscriber (Helidon Project 2.6.13 API)

java.lang.Object
- io.helidon.common.reactive.SequentialSubscriber<T>

Type Parameters:

T - Type of the item

All Implemented Interfaces:

Flow.Subscriber<T>
```
public class SequentialSubscriber<T>
extends Object
implements Flow.Subscriber<T>
```
Wrapper Flow.Subscriber ensuring OnSubscribe, onNext, onError and onComplete to be signaled serially.

See Also:

https://github.com/reactive-streams/reactive-streams-jvm#1.3

Constructor Summary

Constructors
Modifier	Constructor	Description
`protected`	`SequentialSubscriber(Flow.Subscriber<T> subscriber)`	Provides protection from untrusted publishers, enforces rule 1.3 by serializing all parallel calls.

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`static <T> SequentialSubscriber<T>`	`create(Flow.Subscriber<T> subscriber)`	Wrapper `Flow.Subscriber` ensuring `OnSubscribe`, `onNext`, `onError` and `onComplete` to be signaled serially.
`void`	`onComplete()`
`void`	`onError(Throwable throwable)`
`void`	`onNext(T item)`
`void`	`onSubscribe(Flow.Subscription subscription)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - SequentialSubscriber
```
protected SequentialSubscriber(Flow.Subscriber<T> subscriber)
```
    Provides protection from untrusted publishers, enforces rule 1.3 by serializing all parallel calls.
    
    Parameters:
    
    subscriber - to be protected
- Method Detail
  - create
```
public static <T> SequentialSubscriber<T> create(Flow.Subscriber<T> subscriber)
```
    Wrapper Flow.Subscriber ensuring OnSubscribe, onNext, onError and onComplete to be signaled serially.
    
    Type Parameters:
    
    T - item type
    
    Parameters:
    
    subscriber - Flow.Subscriber to be wrapped.
    
    Returns:
    
    new SequentialSubscriber
  - onSubscribe
```
public void onSubscribe(Flow.Subscription subscription)
```
    Specified by:
    
    onSubscribe in interface Flow.Subscriber<T>
  - onNext
```
public void onNext(T item)
```
    Specified by:
    
    onNext in interface Flow.Subscriber<T>
  - onError
```
public void onError(Throwable throwable)
```
    Specified by:
    
    onError in interface Flow.Subscriber<T>
  - onComplete
```
public void onComplete()
```
    Specified by:
    
    onComplete in interface Flow.Subscriber<T>