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.RxDelegateBase interface for a stream.NOTE: This class has been automatically generated from the
originalnon RX-ified interface using Vert.x codegen.
-
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Modifier and Type Method Description StreamBaseexceptionHandler(Handler<Throwable> handler)Set an exception handler.StreamBasegetDelegate()static StreamBasenewInstance(StreamBase arg)
-
-
-
Method Detail
-
getDelegate
StreamBase getDelegate()
- Specified by:
getDelegatein 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)
-
-