io.vertx.core.streams

Interface StreamBase

All Known Subinterfaces:

AmqpReceiver, AmqpSender, AsyncFile, BodyStream<T>, CassandraRowStream, ClientWebSocket, DatagramSocket, GrpcClientRequest<Req,Resp>, GrpcClientResponse<Req,Resp>, GrpcReadStream<T>, GrpcServerRequest<Req,Resp>, GrpcServerResponse<Req,Resp>, GrpcWriteStream<T>, HttpClientRequest, HttpClientResponse, HttpServerFileUpload, HttpServerRequest, HttpServerResponse, JsonParser, KafkaConsumer<K,V>, KafkaProducer<K,V>, KafkaReadStream<K,V>, KafkaWriteStream<K,V>, MessageConsumer<T>, NetSocket, PgChannel, RabbitMQConsumer, ReactiveReadStream<T>, ReactiveWriteStream<T>, ReadStream<T>, RecordParser, RedisConnection, RowStream<T>, ServerWebSocket, SockJSSocket, SQLRowStream, TestSuiteReport, TimeoutStream, WebServerRequest, WebSocket, WebSocketBase, WriteStream<T>

All Known Implementing Classes:

GrpcWriteStream, ReadStreamSubscriber

public interface StreamBase

Base interface for a stream.

Author:

Tim Fox

Method Summary

Modifier and Type	Method and Description
StreamBase	exceptionHandler(Handler<Throwable> handler) Set an exception handler.

Method Detail

exceptionHandler

StreamBase exceptionHandler(Handler<Throwable> handler)

Set an exception handler.

Parameters:

handler - the handler

Returns:

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