Package org.jboss.resteasy.reactive.client.handlers

Class AsyncInputStream

java.lang.Object

org.jboss.resteasy.reactive.client.handlers.AsyncInputStream

All Implemented Interfaces:

io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>, io.vertx.core.streams.StreamBase, Closeable, AutoCloseable

public class AsyncInputStream
extends Object
implements io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>, Closeable

Adapt an InputStream to a ReadStream that can be used with a Pump in Vertx.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AsyncInputStream.InboundBuffer

Field Summary

Fields

Modifier and Type	Field	Description
static final String	INPUTSTREAM_IS_CLOSED

Constructor Summary

Constructors

Constructor	Description
AsyncInputStream(io.vertx.core.Vertx vertx, InputStream in, int maxChunkSize)	Create a new Async InputStream that can we used with a Pump

Method Summary

Modifier and Type	Method	Description
void	close()
void	close(io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> handler)	Close using a specific handler.
AsyncInputStream	endHandler(io.vertx.core.Handler<Void> endHandler)
AsyncInputStream	exceptionHandler(io.vertx.core.Handler<Throwable> exceptionHandler)
io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>	fetch(long amount)
AsyncInputStream	handler(io.vertx.core.Handler<io.vertx.core.buffer.Buffer> handler)
AsyncInputStream	pause()
AsyncInputStream	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 Details

INPUTSTREAM_IS_CLOSED

public static final String INPUTSTREAM_IS_CLOSED

See Also:

• Constant Field Values

Constructor Details

AsyncInputStream

public AsyncInputStream(io.vertx.core.Vertx vertx,
 InputStream in,
 int maxChunkSize)

Create a new Async InputStream that can we used with a Pump

Method Details

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

close

public void close(io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> handler)

Close using a specific handler.

exceptionHandler

public AsyncInputStream exceptionHandler(io.vertx.core.Handler<Throwable> exceptionHandler)

Specified by:

exceptionHandler in interface io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>

Specified by:

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

handler

public AsyncInputStream handler(io.vertx.core.Handler<io.vertx.core.buffer.Buffer> handler)

Specified by:

handler in interface io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>

pause

public AsyncInputStream pause()

Specified by:

pause in interface io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>

resume

public AsyncInputStream resume()

Specified by:

resume in interface io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>

fetch

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

Specified by:

fetch in interface io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>

endHandler

public AsyncInputStream endHandler(io.vertx.core.Handler<Void> endHandler)

Specified by:

endHandler in interface io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>