Package io.micronaut.http.netty

Class PublisherAsBlocking<T>

java.lang.Object

io.micronaut.http.netty.PublisherAsBlocking<T>

Type Parameters:

T - Stream type

All Implemented Interfaces:

Closeable, AutoCloseable, Subscriber<T>

@Internal
public final class PublisherAsBlocking<T>
extends Object
implements Subscriber<T>, Closeable

A subscriber that allows blocking reads from a publisher. Handles resource cleanup properly.

Since:

4.2.0

Author:

Jonas Konrad

Constructor Summary

Constructors

Constructor	Description
PublisherAsBlocking()

Method Summary

Modifier and Type	Method	Description
void	close()
@Nullable Throwable	getFailure()	The failure from onError(Throwable).
void	onComplete()
void	onError(Throwable t)
void	onNext(T o)
void	onSubscribe(Subscription s)
T	take()	Get the next object.

Methods inherited from class java.lang.Object

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

Constructor Details

PublisherAsBlocking

public PublisherAsBlocking()

Method Details

getFailure

@Nullable
public @Nullable Throwable getFailure()

The failure from onError(Throwable). When take() returns null, this may be set if the reactive stream ended in failure.

Returns:

The failure, or null if either the stream is not done, or the stream completed successfully.

onSubscribe

public void onSubscribe(Subscription s)

Specified by:

onSubscribe in interface Subscriber<T>

onNext

public void onNext(T o)

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>

take

@Nullable
public T take()
       throws InterruptedException

Get the next object.

Returns:

The next object, or null if the stream is done

Throws:

InterruptedException

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable