Package io.vertx.reactivex.core.streams
Interface StreamBase
-
- All Known Subinterfaces:
ReadStream<T>
,WebSocketBase
,WriteStream<T>
- All Known Implementing Classes:
AmqpReceiver
,AmqpSender
,AsyncFile
,CassandraRowStream
,ClientWebSocket
,GrpcClientRequest
,GrpcClientResponse
,GrpcReadStream
,GrpcServerRequest
,GrpcServerResponse
,GrpcWriteStream
,HttpClientRequest
,HttpClientResponse
,HttpServerFileUpload
,HttpServerRequest
,HttpServerResponse
,JsonParser
,KafkaConsumer
,KafkaProducer
,MessageConsumer
,NetSocket
,PgChannel
,RabbitMQConsumer
,RecordParser
,RedisConnection
,RowStream
,ServerWebSocket
,SockJSSocket
,TestSuiteReport
,WebSocket
public interface StreamBase
Base interface for a stream.NOTE: This class has been automatically generated from the
original
non RX-ified interface using Vert.x codegen.
-
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Modifier and Type Method Description StreamBase
exceptionHandler(Handler<Throwable> handler)
Set an exception handler.StreamBase
getDelegate()
static StreamBase
newInstance(StreamBase arg)
-
-
-
Method Detail
-
getDelegate
StreamBase getDelegate()
-
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
-
newInstance
static StreamBase newInstance(StreamBase arg)
-
-