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, Flow.Subscriber<R>

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

Field Summary

Fields

Modifier and Type	Field	Description
static final 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(Flow.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(Flow.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

collect, pipe, pipeTo, pipeTo

Field Details

BUFFER_SIZE

public static final int BUFFER_SIZE

See Also:

• Constant Field Values

Constructor Details

ReadStreamSubscriber

public ReadStreamSubscriber(Function<R,J> adapter)

Method Details

asReadStream

public static <R,
J>
io.vertx.core.streams.ReadStream<J> asReadStream(Flow.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(Flow.Subscription s)

Specified by:

onSubscribe in interface Flow.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 Flow.Subscriber<R>

onError

public void onError(Throwable e)

Specified by:

onError in interface Flow.Subscriber<R>

onNext

public void onNext(R item)

Specified by:

onNext in interface Flow.Subscriber<R>