Uses of Interface
io.smallrye.mutiny.vertx.WriteStreamSubscriber

Packages that use WriteStreamSubscriber

Package	Description
io.smallrye.mutiny.vertx
io.vertx.mutiny.amqp
io.vertx.mutiny.core.file
io.vertx.mutiny.core.http
io.vertx.mutiny.core.net
io.vertx.mutiny.ext.web.handler.sockjs
io.vertx.mutiny.kafka.client.producer

Uses of WriteStreamSubscriber in io.smallrye.mutiny.vertx

Methods in io.smallrye.mutiny.vertx that return WriteStreamSubscriber

Modifier and Type	Method	Description
WriteStreamSubscriber<T>	WriteStreamSubscriber.onComplete(Runnable callback)	Sets the handler to invoke on completion events.
WriteStreamSubscriber<T>	WriteStreamSubscriber.onFailure(Consumer<? super Throwable> callback)	Sets the handler to invoke on failure events.
WriteStreamSubscriber<T>	WriteStreamSubscriber.onWriteStreamError(Consumer<? super Throwable> callback)	Sets the handler to invoke if the adapted WriteStream fails.
static <T> WriteStreamSubscriber<T>	MutinyHelper.toSubscriber(io.vertx.core.streams.WriteStream<T> stream)	Adapts a Vert.x WriteStream to a Mutiny Flow.Subscriber.
static <R, T> WriteStreamSubscriber<R>	MutinyHelper.toSubscriber(io.vertx.core.streams.WriteStream<T> stream, Function<R,T> mapping)	Like MutinyHelper.toSubscriber(WriteStream), except the provided mapping function is applied to each item.

Uses of WriteStreamSubscriber in io.vertx.mutiny.amqp

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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