Interface StreamBase

All Superinterfaces:
io.vertx.lang.rx.RxDelegate
All Known Subinterfaces:
ReadStream<T>, StreamChannel, 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, QuicStream, 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 Details

    • getDelegate

      StreamBase getDelegate()
      Specified by:
      getDelegate in interface io.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)