Package io.smallrye.mutiny.vertx

Class ReadStreamSubscriber<R,J>

java.lang.Object

io.smallrye.mutiny.vertx.ReadStreamSubscriber<R,J>

All Implemented Interfaces:

io.vertx.core.streams.ReadStream<J>, io.vertx.core.streams.StreamBase, org.reactivestreams.Subscriber<R>

public class ReadStreamSubscriber<R,J>
extends Object
implements org.reactivestreams.Subscriber<R>, io.vertx.core.streams.ReadStream<J>

Field Summary

Fields

Modifier and Type	Field	Description
static int	BUFFER_SIZE

Constructor Summary

Constructors

Constructor	Description
ReadStreamSubscriber(Function<R,J> adapter)

Method Summary

Modifier and Type	Method	Description
static <R,J> io.vertx.core.streams.ReadStream<J>	asReadStream(org.reactivestreams.Publisher<R> multi, Function<R,J> adapter)
io.vertx.core.streams.ReadStream<J>	endHandler(io.vertx.core.Handler<Void> handler)
io.vertx.core.streams.ReadStream<J>	exceptionHandler(io.vertx.core.Handler<Throwable> handler)
io.vertx.core.streams.ReadStream<J>	fetch(long amount)
io.vertx.core.streams.ReadStream<J>	handler(io.vertx.core.Handler<J> handler)
void	onComplete()
void	onError(Throwable e)
void	onNext(R item)
void	onSubscribe(org.reactivestreams.Subscription s)
io.vertx.core.streams.ReadStream<J>	pause()
io.vertx.core.streams.ReadStream<J>	resume()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.vertx.core.streams.ReadStream

pipe, pipeTo, pipeTo

Field Detail

BUFFER_SIZE

public static final int BUFFER_SIZE

See Also:

Constant Field Values

Constructor Detail

ReadStreamSubscriber

public ReadStreamSubscriber(Function<R,J> adapter)

Method Detail

asReadStream

public static <R,J> io.vertx.core.streams.ReadStream<J> asReadStream(org.reactivestreams.Publisher<R> multi,
                                                                           Function<R,J> adapter)

handler

public io.vertx.core.streams.ReadStream<J> handler(io.vertx.core.Handler<J> handler)

Specified by:

handler in interface io.vertx.core.streams.ReadStream<R>

pause

public io.vertx.core.streams.ReadStream<J> pause()

Specified by:

pause in interface io.vertx.core.streams.ReadStream<R>

fetch

public io.vertx.core.streams.ReadStream<J> fetch(long amount)

Specified by:

fetch in interface io.vertx.core.streams.ReadStream<R>

resume

public io.vertx.core.streams.ReadStream<J> resume()

Specified by:

resume in interface io.vertx.core.streams.ReadStream<R>

onSubscribe

public void onSubscribe(org.reactivestreams.Subscription s)

Specified by:

onSubscribe in interface org.reactivestreams.Subscriber<R>

endHandler

public io.vertx.core.streams.ReadStream<J> endHandler(io.vertx.core.Handler<Void> handler)

Specified by:

endHandler in interface io.vertx.core.streams.ReadStream<R>

exceptionHandler

public io.vertx.core.streams.ReadStream<J> exceptionHandler(io.vertx.core.Handler<Throwable> handler)

Specified by:

exceptionHandler in interface io.vertx.core.streams.ReadStream<R>

Specified by:

exceptionHandler in interface io.vertx.core.streams.StreamBase

onComplete

public void onComplete()

Specified by:

onComplete in interface org.reactivestreams.Subscriber<R>

onError

public void onError(Throwable e)

Specified by:

onError in interface org.reactivestreams.Subscriber<R>

onNext

public void onNext(R item)

Specified by:

onNext in interface org.reactivestreams.Subscriber<R>