Package io.micronaut.core.async.publisher

Class DelayedSubscriber<T>

java.lang.Object

io.micronaut.core.async.publisher.DelayedSubscriber<T>

Type Parameters:

T - The forwarded type

All Implemented Interfaces:

Processor<T,T>, Publisher<T>, Subscriber<T>, Subscription

@Internal
public final class DelayedSubscriber<T>
extends Object
implements Processor<T,T>, Subscription

This is a Processor that does not change the stream, but allows the upstream Publisher and downstream Subscriber to be set independently in any order. If the upstream is set first, this class makes sure that any early completion is held back until the downstream has finished onSubscribe. If the downstream is set first, this class makes sure any demand is stored until the upstream becomes available.

Since:

4.4.0

Author:

Jonas Konrad

Constructor Summary

Constructors

Constructor	Description
DelayedSubscriber()

Method Summary

Modifier and Type	Method	Description
void	cancel()
void	onComplete()
void	onError(Throwable t)
void	onNext(T t)
void	onSubscribe(Subscription s)
void	request(long n)
void	subscribe(Subscriber<? super T> s)

Methods inherited from class java.lang.Object

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

Constructor Details

DelayedSubscriber

public DelayedSubscriber()

Method Details

subscribe

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

Specified by:

subscribe in interface Publisher<T>

onSubscribe

public void onSubscribe(Subscription s)

Specified by:

onSubscribe in interface Subscriber<T>

onNext

public void onNext(T t)

Specified by:

onNext in interface Subscriber<T>

onError

public void onError(Throwable t)

Specified by:

onError in interface Subscriber<T>

onComplete

public void onComplete()

Specified by:

onComplete in interface Subscriber<T>

request

public void request(long n)

Specified by:

request in interface Subscription

cancel

public void cancel()

Specified by:

cancel in interface Subscription