Package io.vertx.rxjava3.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)
-
-