Package io.vertx.reactivex.core.streams
Interface StreamBase
-
- All Superinterfaces:
io.vertx.lang.rx.RxDelegate
- 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 extends io.vertx.lang.rx.RxDelegate
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()
- Specified by:
getDelegate
in interfaceio.vertx.lang.rx.RxDelegate
-
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)
-
-