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 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)