Package io.vertx.mutiny.core.streams

Class StreamBase.StreamBaseImpl

java.lang.Object

io.vertx.mutiny.core.streams.StreamBase.StreamBaseImpl

All Implemented Interfaces:

MutinyDelegate, StreamBase

Enclosing interface:

StreamBase

public static class StreamBase.StreamBaseImpl
extends Object
implements StreamBase

Nested Class Summary

Nested classes/interfaces inherited from interface io.vertx.mutiny.core.streams.StreamBase

StreamBase.StreamBaseImpl

Constructor Summary

Constructors

Constructor	Description
StreamBaseImpl(io.vertx.core.streams.StreamBase delegate)	Create a new instance of StreamBase.StreamBaseImpl delegating to the given (non-null) instance of StreamBase.

Method Summary

Modifier and Type	Method	Description
StreamBase.StreamBaseImpl	exceptionHandler(Consumer<Throwable> handler)	Set an exception handler.
io.vertx.core.streams.StreamBase	getDelegate()	Get the delegate instance.

Methods inherited from class java.lang.Object

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

Constructor Details

StreamBaseImpl

public StreamBaseImpl(io.vertx.core.streams.StreamBase delegate)

Create a new instance of StreamBase.StreamBaseImpl delegating to the given (non-null) instance of StreamBase.

Method Details

getDelegate

public io.vertx.core.streams.StreamBase getDelegate()

Get the delegate instance.

This method returns the instance on which this shim is delegating the calls. And so, give you access to the bare API.

Specified by:

getDelegate in interface MutinyDelegate

Specified by:

getDelegate in interface StreamBase

Returns:

the delegate instance

exceptionHandler

public StreamBase.StreamBaseImpl exceptionHandler(Consumer<Throwable> handler)

Set an exception handler.

Specified by:

exceptionHandler in interface StreamBase

Parameters:

handler - the handler. Can be null.

Returns:

a reference to this, so the API can be used fluently