Package io.vertx.mutiny.core.streams

Interface StreamBase

All Superinterfaces:

MutinyDelegate

All Known Subinterfaces:

ReadStream<T>, StreamChannel, WebSocketBase, WriteStream<T>

All Known Implementing Classes:

AmqpReceiver, AmqpSender, AsyncFile, CassandraRowStream, ClientWebSocket, HttpClientRequest, HttpClientResponse, HttpServerFileUpload, HttpServerRequest, HttpServerResponse, JsonParser, KafkaConsumer, KafkaProducer, MessageConsumer, NetSocket, PgChannel, QuicStream, RabbitMQConsumer, ReadStream.ReadStreamImpl, RecordParser, RedisConnection, RowStream, ServerWebSocket, SockJSSocket, StreamBase.StreamBaseImpl, StreamChannel.StreamChannelImpl, WebSocket, WebSocketBase.WebSocketBaseImpl, WriteStream.WriteStreamImpl

public interface StreamBase
extends MutinyDelegate

Base interface for a stream.

NOTE: This class has been automatically generated from the original non Mutiny-ified interface.

Author:

Tim Fox

See Also:

• StreamBase

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	StreamBase.StreamBaseImpl

Method Summary

Modifier and Type	Method	Description
StreamBase	exceptionHandler(Consumer<Throwable> handler)	Set an exception handler.
io.vertx.core.streams.StreamBase	getDelegate()
static StreamBase	newInstance(io.vertx.core.streams.StreamBase delegate)	Creates a new instance of the StreamBase.

Method Details

getDelegate

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

Specified by:

getDelegate in interface MutinyDelegate

Returns:

the delegate used by this Mutiny object of generated type

exceptionHandler

StreamBase exceptionHandler(Consumer<Throwable> handler)

Set an exception handler.

Parameters:

handler - the handler. Can be null.

Returns:

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

newInstance

static StreamBase newInstance(io.vertx.core.streams.StreamBase delegate)

Creates a new instance of the StreamBase.