Uses of Class
io.vertx.rx.java.WriteStreamSubscriber

Packages that use WriteStreamSubscriber

Package	Description
io.vertx.rx.java
io.vertx.rx.java.impl
io.vertx.rxjava.amqp
io.vertx.rxjava.core.eventbus
io.vertx.rxjava.core.file
io.vertx.rxjava.core.http
io.vertx.rxjava.core.net
io.vertx.rxjava.ext.web.handler.sockjs
io.vertx.rxjava.kafka.client.producer

Uses of WriteStreamSubscriber in io.vertx.rx.java

Methods in io.vertx.rx.java that return WriteStreamSubscriber

Modifier and Type	Method and Description
abstract WriteStreamSubscriber<R>	WriteStreamSubscriber.onComplete(Action0 handler) Deprecated. because the handler may be called while there are outstanding writes in the underlying WriteStream. Use onWriteStreamEnd(Action0) instead.
abstract WriteStreamSubscriber<R>	WriteStreamSubscriber.onError(Action1<Throwable> handler) Sets the handler to invoke if the Observable that was subscribed to terminates with an error.
abstract WriteStreamSubscriber<R>	WriteStreamSubscriber.onWriteStreamEnd(Action0 handler) Sets the handler to invoke when the adapted WriteStream ends successfully.
abstract WriteStreamSubscriber<R>	WriteStreamSubscriber.onWriteStreamEndError(Action1<Throwable> handler) Sets the handler to invoke when the adapted WriteStream ends with an error.
abstract WriteStreamSubscriber<R>	WriteStreamSubscriber.onWriteStreamError(Action1<Throwable> handler) Sets the handler to invoke if the adapted WriteStream fails.
static <T> WriteStreamSubscriber<T>	RxHelper.toSubscriber(WriteStream<T> stream) Adapts a Vert.x WriteStream to an RxJava Subscriber.
static <R,T> WriteStreamSubscriber<R>	RxHelper.toSubscriber(WriteStream<T> stream, Function<R,T> mapping) Like RxHelper.toSubscriber(WriteStream), except the provided mapping function is applied to each Observable item.

Uses of WriteStreamSubscriber in io.vertx.rx.java.impl

Subclasses of WriteStreamSubscriber in io.vertx.rx.java.impl

Modifier and Type	Class and Description
class	WriteStreamSubscriberImpl<R,T>

Methods in io.vertx.rx.java.impl that return WriteStreamSubscriber

Modifier and Type	Method and Description
WriteStreamSubscriber<R>	WriteStreamSubscriberImpl.onComplete(Action0 handler)
WriteStreamSubscriber<R>	WriteStreamSubscriberImpl.onError(Action1<Throwable> handler)
WriteStreamSubscriber<R>	WriteStreamSubscriberImpl.onWriteStreamEnd(Action0 handler)
WriteStreamSubscriber<R>	WriteStreamSubscriberImpl.onWriteStreamEndError(Action1<Throwable> handler)
WriteStreamSubscriber<R>	WriteStreamSubscriberImpl.onWriteStreamError(Action1<Throwable> handler)

Uses of WriteStreamSubscriber in io.vertx.rxjava.amqp

Methods in io.vertx.rxjava.amqp that return WriteStreamSubscriber

Modifier and Type	Method and Description
WriteStreamSubscriber<AmqpMessage>	AmqpSender.toSubscriber()

Uses of WriteStreamSubscriber in io.vertx.rxjava.core.eventbus

Methods in io.vertx.rxjava.core.eventbus that return WriteStreamSubscriber

Modifier and Type	Method and Description
WriteStreamSubscriber<T>	MessageProducer.toSubscriber()

Uses of WriteStreamSubscriber in io.vertx.rxjava.core.file

Methods in io.vertx.rxjava.core.file that return WriteStreamSubscriber

Modifier and Type	Method and Description
WriteStreamSubscriber<Buffer>	AsyncFile.toSubscriber()

Uses of WriteStreamSubscriber in io.vertx.rxjava.core.http

Methods in io.vertx.rxjava.core.http that return WriteStreamSubscriber

Modifier and Type	Method and Description
WriteStreamSubscriber<Buffer>	HttpClientRequest.toSubscriber()
WriteStreamSubscriber<Buffer>	WebSocket.toSubscriber()
WriteStreamSubscriber<Buffer>	HttpServerResponse.toSubscriber()
WriteStreamSubscriber<Buffer>	ServerWebSocket.toSubscriber()

Uses of WriteStreamSubscriber in io.vertx.rxjava.core.net

Methods in io.vertx.rxjava.core.net that return WriteStreamSubscriber

Modifier and Type	Method and Description
WriteStreamSubscriber<Buffer>	NetSocket.toSubscriber()

Uses of WriteStreamSubscriber in io.vertx.rxjava.ext.web.handler.sockjs

Methods in io.vertx.rxjava.ext.web.handler.sockjs that return WriteStreamSubscriber

Modifier and Type	Method and Description
WriteStreamSubscriber<Buffer>	SockJSSocket.toSubscriber()

Uses of WriteStreamSubscriber in io.vertx.rxjava.kafka.client.producer

Methods in io.vertx.rxjava.kafka.client.producer that return WriteStreamSubscriber

Modifier and Type	Method and Description
WriteStreamSubscriber<KafkaProducerRecord<K,V>>	KafkaProducer.toSubscriber()