Modifier and Type | Class and Description |
---|---|
class |
EmptyCompletionHandler<E>
Empty implementation for
CompletionHandler interface. |
Modifier and Type | Method and Description |
---|---|
void |
GrizzlyFuture.addCompletionHandler(CompletionHandler<R> completionHandler)
Adds a
CompletionHandler , which will be notified once the
asynchronous computation, represented by this Future,
is complete. |
void |
Connection.close(CompletionHandler<Closeable> completionHandler)
Deprecated.
use
Connection.close() with the following GrizzlyFuture.addCompletionHandler(org.glassfish.grizzly.CompletionHandler) . |
void |
Closeable.close(CompletionHandler<Closeable> completionHandler)
Deprecated.
please use
Closeable.close() with the following GrizzlyFuture.addCompletionHandler(org.glassfish.grizzly.CompletionHandler) call |
void |
ConnectorHandler.connect(E remoteAddress,
CompletionHandler<Connection> completionHandler)
Creates, initializes and establishes
Connection to the specific
remoteAddress . |
void |
ConnectorHandler.connect(E remoteAddress,
E localAddress,
CompletionHandler<Connection> completionHandler)
Creates, initializes
Connection , binds it to the specific local
and remote remoteAddress . |
void |
AbstractSocketConnectorHandler.connect(SocketAddress remoteAddress,
CompletionHandler<Connection> completionHandler) |
void |
AbstractSocketConnectorHandler.connect(SocketAddress remoteAddress,
SocketAddress localAddress,
CompletionHandler<Connection> completionHandler) |
protected abstract FutureImpl<Connection> |
AbstractSocketConnectorHandler.connectAsync(SocketAddress remoteAddress,
SocketAddress localAddress,
CompletionHandler<Connection> completionHandler,
boolean needFuture) |
<M> void |
Readable.read(CompletionHandler<ReadResult<M,L>> completionHandler) |
void |
Reader.read(Connection<L> connection,
Buffer buffer,
CompletionHandler<ReadResult<Buffer,L>> completionHandler)
Method reads data to the buffer.
|
void |
AbstractReader.read(Connection<L> connection,
Buffer buffer,
CompletionHandler<ReadResult<Buffer,L>> completionHandler)
Method reads data to the buffer.
|
void |
Reader.read(Connection<L> connection,
Buffer buffer,
CompletionHandler<ReadResult<Buffer,L>> completionHandler,
Interceptor<ReadResult> interceptor)
Method reads data to the buffer.
|
void |
StandaloneProcessor.read(Connection connection,
CompletionHandler completionHandler) |
void |
Processor.read(Connection connection,
CompletionHandler<ReadResult> completionHandler) |
void |
AbstractWriter.write(Connection<L> connection,
L dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,L>> completionHandler)
Method writes the
WritableMessage to the specific address. |
void |
Writer.write(Connection<L> connection,
L dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,L>> completionHandler)
Method writes the
WritableMessage to the specific address. |
void |
Writer.write(Connection<L> connection,
L dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,L>> completionHandler,
MessageCloner<WritableMessage> messageCloner)
Method writes the
WritableMessage to the specific address. |
void |
Writer.write(Connection<L> connection,
L dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,L>> completionHandler,
PushBackHandler pushBackHandler)
Deprecated.
push back logic is deprecated
|
void |
AbstractWriter.write(Connection<L> connection,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,L>> completionHandler)
Method writes the
WritableMessage . |
void |
Writer.write(Connection<L> connection,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,L>> completionHandler)
Method writes the
WritableMessage . |
void |
StandaloneProcessor.write(Connection connection,
Object dstAddress,
Object message,
CompletionHandler completionHandler) |
void |
Processor.write(Connection connection,
Object dstAddress,
Object message,
CompletionHandler<WriteResult> completionHandler) |
void |
Processor.write(Connection connection,
Object dstAddress,
Object message,
CompletionHandler<WriteResult> completionHandler,
MessageCloner messageCloner) |
void |
Processor.write(Connection connection,
Object dstAddress,
Object message,
CompletionHandler<WriteResult> completionHandler,
PushBackHandler pushBackHandler)
Deprecated.
|
void |
StandaloneProcessor.write(Connection connection,
Object dstAddress,
Object message,
CompletionHandler completionHandler,
MessageCloner messageCloner) |
void |
StandaloneProcessor.write(Connection connection,
Object dstAddress,
Object message,
CompletionHandler completionHandler,
PushBackHandler pushBackHandler)
Deprecated.
|
<M> void |
Writeable.write(L dstAddress,
M message,
CompletionHandler<WriteResult<M,L>> completionHandler)
Method writes the buffer to the specific address.
|
<M> void |
Writeable.write(L dstAddress,
M message,
CompletionHandler<WriteResult<M,L>> completionHandler,
PushBackHandler pushbackHandler)
Deprecated.
push back logic is deprecated
|
<M> void |
Writeable.write(M message,
CompletionHandler<WriteResult<M,L>> completionHandler)
Method writes the buffer.
|
<M> void |
Writeable.write(M message,
CompletionHandler<WriteResult<M,L>> completionHandler,
PushBackHandler pushbackHandler)
Deprecated.
push back logic is deprecated
|
Modifier and Type | Field and Description |
---|---|
protected CompletionHandler |
AsyncQueueRecord.completionHandler |
Modifier and Type | Method and Description |
---|---|
static AsyncReadQueueRecord |
AsyncReadQueueRecord.create(Connection connection,
Buffer message,
CompletionHandler completionHandler,
Interceptor<ReadResult> interceptor) |
static AsyncWriteQueueRecord |
AsyncWriteQueueRecord.create(Connection connection,
WritableMessage message,
CompletionHandler completionHandler,
Object dstAddress,
PushBackHandler pushbackHandler,
boolean isUncountable) |
protected void |
AsyncQueueRecord.set(Connection connection,
Object message,
CompletionHandler completionHandler) |
protected void |
AsyncReadQueueRecord.set(Connection connection,
Object message,
CompletionHandler completionHandler,
Interceptor interceptor) |
protected void |
AsyncWriteQueueRecord.set(Connection connection,
WritableMessage message,
CompletionHandler completionHandler,
Object dstAddress,
PushBackHandler pushBackHandler,
boolean isUncountable) |
void |
AsyncQueueWriter.write(Connection<L> connection,
L dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,L>> completionHandler,
PushBackHandler pushBackHandler,
MessageCloner<WritableMessage> cloner)
Deprecated.
push back logic is deprecated
|
Constructor and Description |
---|
AsyncQueueRecord(Connection connection,
Object message,
CompletionHandler completionHandler) |
AsyncWriteQueueRecord(Connection connection,
WritableMessage message,
CompletionHandler completionHandler,
Object dstAddress,
PushBackHandler pushBackHandler,
boolean isUncountable) |
Modifier and Type | Method and Description |
---|---|
void |
SingleEndpointPool.take(CompletionHandler<Connection> completionHandler)
Obtains a
Connection from the pool in non-blocking/asynchronous fashion. |
void |
MultiEndpointPool.take(EndpointKey<E> endpointKey,
CompletionHandler<Connection> completionHandler)
Obtains a
Connection to the specified endpoint from the pool
in non-blocking/asynchronous fashion. |
Modifier and Type | Field and Description |
---|---|
protected CompletionHandler<FilterChainContext> |
FilterChainContext.operationCompletionHandler
CompletionHandler , which will be notified, when operation will be
complete. |
Modifier and Type | Method and Description |
---|---|
CompletionHandler |
TransportFilter.FlushEvent.getCompletionHandler() |
CompletionHandler |
FilterChainContext.TransportContext.getCompletionHandler() |
Modifier and Type | Method and Description |
---|---|
static FilterChainEvent |
TransportFilter.createFlushEvent(CompletionHandler completionHandler) |
void |
FilterChain.fireEventDownstream(Connection connection,
FilterChainEvent event,
CompletionHandler<FilterChainContext> completionHandler) |
void |
DefaultFilterChain.fireEventDownstream(Connection connection,
FilterChainEvent event,
CompletionHandler<FilterChainContext> completionHandler) |
void |
FilterChain.fireEventUpstream(Connection connection,
FilterChainEvent event,
CompletionHandler<FilterChainContext> completionHandler) |
void |
DefaultFilterChain.fireEventUpstream(Connection connection,
FilterChainEvent event,
CompletionHandler<FilterChainContext> completionHandler) |
void |
FilterChainContext.flush(CompletionHandler completionHandler) |
void |
FilterChain.flush(Connection connection,
CompletionHandler<WriteResult> completionHandler) |
void |
DefaultFilterChain.flush(Connection connection,
CompletionHandler<WriteResult> completionHandler) |
void |
FilterChainContext.notifyDownstream(FilterChainEvent event,
CompletionHandler<FilterChainContext> completionHandler) |
void |
FilterChainContext.notifyUpstream(FilterChainEvent event,
CompletionHandler<FilterChainContext> completionHandler) |
void |
DefaultFilterChain.read(Connection connection,
CompletionHandler<ReadResult> completionHandler) |
void |
FilterChainContext.TransportContext.setCompletionHandler(CompletionHandler completionHandler) |
void |
DefaultFilterChain.write(Connection connection,
Object dstAddress,
Object message,
CompletionHandler<WriteResult> completionHandler) |
void |
DefaultFilterChain.write(Connection connection,
Object dstAddress,
Object message,
CompletionHandler<WriteResult> completionHandler,
MessageCloner messageCloner) |
void |
DefaultFilterChain.write(Connection connection,
Object dstAddress,
Object message,
CompletionHandler completionHandler,
PushBackHandler pushBackHandler)
Deprecated.
|
void |
FilterChainContext.write(Object message,
CompletionHandler<WriteResult> completionHandler) |
void |
FilterChainContext.write(Object message,
CompletionHandler<WriteResult> completionHandler,
boolean blocking) |
void |
FilterChainContext.write(Object address,
Object message,
CompletionHandler<WriteResult> completionHandler) |
void |
FilterChainContext.write(Object address,
Object message,
CompletionHandler<WriteResult> completionHandler,
boolean blocking) |
void |
FilterChainContext.write(Object address,
Object message,
CompletionHandler<WriteResult> completionHandler,
MessageCloner cloner) |
void |
FilterChainContext.write(Object address,
Object message,
CompletionHandler<WriteResult> completionHandler,
MessageCloner cloner,
boolean blocking) |
void |
FilterChainContext.write(Object address,
Object message,
CompletionHandler<WriteResult> completionHandler,
PushBackHandler pushBackHandler)
Deprecated.
|
void |
FilterChainContext.write(Object address,
Object message,
CompletionHandler<WriteResult> completionHandler,
PushBackHandler pushBackHandler,
boolean blocking)
Deprecated.
|
void |
FilterChainContext.write(Object address,
Object message,
CompletionHandler<WriteResult> completionHandler,
PushBackHandler pushBackHandler,
MessageCloner cloner)
Deprecated.
|
void |
FilterChainContext.write(Object address,
Object message,
CompletionHandler<WriteResult> completionHandler,
PushBackHandler pushBackHandler,
MessageCloner cloner,
boolean blocking)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
OutputBuffer.sendfile(File file,
CompletionHandler<WriteResult> handler)
Calls
write(file, 0, file.length()) . |
void |
OutputBuffer.sendfile(File file,
long offset,
long length,
CompletionHandler<WriteResult> handler)
Will use
FileChannel.transferTo(long, long, java.nio.channels.WritableByteChannel)
to send file to the remote endpoint. |
Modifier and Type | Method and Description |
---|---|
static void |
MultipartScanner.scan(MultipartEntry multipartMixedEntry,
MultipartEntryHandler partHandler,
CompletionHandler<MultipartEntry> completionHandler)
Initialize the multipart/mixed
MultipartEntry processing. |
static void |
MultipartScanner.scan(Request request,
MultipartEntryHandler partHandler,
CompletionHandler<Request> completionHandler)
Initialize the multipart HTTP request processing.
|
Constructor and Description |
---|
MultipartReadHandler(MultipartEntry parentMultipartEntry,
MultipartEntryHandler multipartHandler,
CompletionHandler<MultipartEntry> completionHandler,
MultipartContext multipartContext) |
MultipartReadHandler(Request request,
MultipartEntryHandler multipartHandler,
CompletionHandler<Request> completionHandler,
MultipartContext multipartContext) |
Modifier and Type | Method and Description |
---|---|
CompletionHandler<Response> |
SuspendContext.getCompletionHandler()
Get the suspended
Response CompletionHandler . |
CompletionHandler<Response> |
Response.SuspendedContextImpl.getCompletionHandler() |
Modifier and Type | Method and Description |
---|---|
void |
HttpServerFilter.prepareForShutdown(CompletionHandler<HttpServerFilter> shutdownCompletionHandler)
Method, which might be optionally called to prepare the filter for
shutdown.
|
void |
Response.suspend(long timeout,
TimeUnit timeunit,
CompletionHandler<Response> completionHandler)
Suspend the
Response . |
void |
Response.suspend(long timeout,
TimeUnit timeunit,
CompletionHandler<Response> completionHandler,
TimeoutHandler timeoutHandler)
Suspend the
Response . |
Modifier and Type | Method and Description |
---|---|
void |
ServerOutputBuffer.sendfile(File file,
long offset,
long length,
CompletionHandler<WriteResult> handler) |
Modifier and Type | Field and Description |
---|---|
protected Set<CompletionHandler<R>> |
UnsafeFutureImpl.completionHandlers |
Modifier and Type | Method and Description |
---|---|
void |
SafeFutureImpl.addCompletionHandler(CompletionHandler<R> completionHandler)
Adds a
CompletionHandler , which will be notified once the
asynchronous computation, represented by this Future,
is complete. |
void |
ReadyFutureImpl.addCompletionHandler(CompletionHandler<R> completionHandler)
Adds a
CompletionHandler , which will be notified once the
asynchronous computation, represented by this Future,
is complete. |
void |
UnsafeFutureImpl.addCompletionHandler(CompletionHandler<R> completionHandler)
Adds a
CompletionHandler , which will be notified once the
asynchronous computation, represented by this Future,
is complete. |
Modifier and Type | Method and Description |
---|---|
void |
NIOConnection.close(CompletionHandler<Closeable> completionHandler)
Deprecated.
please use
NIOConnection.close() with the following GrizzlyFuture.addCompletionHandler(org.glassfish.grizzly.CompletionHandler) call |
protected void |
NIOConnection.closeGracefully0(CompletionHandler<Closeable> completionHandler,
CloseReason closeReason) |
protected AsyncWriteQueueRecord |
AbstractNIOAsyncQueueWriter.createRecord(Connection connection,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,SocketAddress>> completionHandler,
SocketAddress dstAddress,
PushBackHandler pushBackHandler,
boolean isUncountable) |
void |
DefaultSelectorHandler.deregisterChannelAsync(SelectorRunner selectorRunner,
SelectableChannel channel,
CompletionHandler<RegisterChannelResult> completionHandler) |
void |
SelectorHandler.deregisterChannelAsync(SelectorRunner selectorRunner,
SelectableChannel channel,
CompletionHandler<RegisterChannelResult> completionHandler)
Deregister the channel from the
SelectorRunner 's Selector. |
void |
DefaultSelectorHandler.enque(SelectorRunner selectorRunner,
SelectorHandler.Task task,
CompletionHandler<SelectorHandler.Task> completionHandler) |
void |
SelectorHandler.enque(SelectorRunner selectorRunner,
SelectorHandler.Task task,
CompletionHandler<SelectorHandler.Task> completionHandler)
Execute task in a selector thread.
|
void |
DefaultSelectorHandler.execute(SelectorRunner selectorRunner,
SelectorHandler.Task task,
CompletionHandler<SelectorHandler.Task> completionHandler) |
void |
SelectorHandler.execute(SelectorRunner selectorRunner,
SelectorHandler.Task task,
CompletionHandler<SelectorHandler.Task> completionHandler)
Execute task in a selector thread.
|
<M> void |
NIOConnection.read(CompletionHandler<ReadResult<M,SocketAddress>> completionHandler) |
void |
AbstractNIOAsyncQueueReader.read(Connection<SocketAddress> connection,
Buffer buffer,
CompletionHandler<ReadResult<Buffer,SocketAddress>> completionHandler,
Interceptor<ReadResult> interceptor)
Method reads data to the buffer.
|
void |
RoundRobinConnectionDistributor.registerChannelAsync(SelectableChannel channel,
int interestOps,
Object attachment,
CompletionHandler<RegisterChannelResult> completionHandler) |
void |
NIOChannelDistributor.registerChannelAsync(SelectableChannel channel,
int interestOps,
Object attachment,
CompletionHandler<RegisterChannelResult> completionHandler) |
void |
DefaultSelectorHandler.registerChannelAsync(SelectorRunner selectorRunner,
SelectableChannel channel,
int interest,
Object attachment,
CompletionHandler<RegisterChannelResult> completionHandler) |
void |
SelectorHandler.registerChannelAsync(SelectorRunner selectorRunner,
SelectableChannel channel,
int interest,
Object attachment,
CompletionHandler<RegisterChannelResult> completionHandler) |
void |
RoundRobinConnectionDistributor.registerServiceChannelAsync(SelectableChannel channel,
int interestOps,
Object attachment,
CompletionHandler<RegisterChannelResult> completionHandler) |
void |
NIOChannelDistributor.registerServiceChannelAsync(SelectableChannel channel,
int interestOps,
Object attachment,
CompletionHandler<RegisterChannelResult> completionHandler) |
protected void |
NIOConnection.terminate0(CompletionHandler<Closeable> completionHandler,
CloseReason closeReason) |
void |
AbstractNIOAsyncQueueWriter.write(Connection<SocketAddress> connection,
SocketAddress dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,SocketAddress>> completionHandler,
MessageCloner<WritableMessage> cloner) |
void |
AbstractNIOAsyncQueueWriter.write(Connection<SocketAddress> connection,
SocketAddress dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,SocketAddress>> completionHandler,
PushBackHandler pushBackHandler)
Deprecated.
|
void |
AbstractNIOAsyncQueueWriter.write(Connection<SocketAddress> connection,
SocketAddress dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,SocketAddress>> completionHandler,
PushBackHandler pushBackHandler,
MessageCloner<WritableMessage> cloner)
Deprecated.
|
<M> void |
NIOConnection.write(M message,
CompletionHandler<WriteResult<M,SocketAddress>> completionHandler) |
<M> void |
NIOConnection.write(M message,
CompletionHandler<WriteResult<M,SocketAddress>> completionHandler,
PushBackHandler pushbackHandler)
Deprecated.
|
<M> void |
NIOConnection.write(SocketAddress dstAddress,
M message,
CompletionHandler<WriteResult<M,SocketAddress>> completionHandler) |
<M> void |
NIOConnection.write(SocketAddress dstAddress,
M message,
CompletionHandler<WriteResult<M,SocketAddress>> completionHandler,
PushBackHandler pushbackHandler)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
TemporarySelectorReader.read(Connection<SocketAddress> connection,
Buffer message,
CompletionHandler<ReadResult<Buffer,SocketAddress>> completionHandler,
Interceptor<ReadResult> interceptor) |
void |
TemporarySelectorReader.read(Connection<SocketAddress> connection,
Buffer message,
CompletionHandler<ReadResult<Buffer,SocketAddress>> completionHandler,
Interceptor<ReadResult> interceptor,
long timeout,
TimeUnit timeunit)
Method reads data to the message.
|
void |
TemporarySelectorWriter.write(Connection<SocketAddress> connection,
SocketAddress dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,SocketAddress>> completionHandler,
long timeout,
TimeUnit timeunit)
Method writes the
WritableMessage to the specific address. |
void |
TemporarySelectorWriter.write(Connection<SocketAddress> connection,
SocketAddress dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,SocketAddress>> completionHandler,
MessageCloner<WritableMessage> messageCloner)
Method writes the
WritableMessage to the specific address. |
void |
TemporarySelectorWriter.write(Connection<SocketAddress> connection,
SocketAddress dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,SocketAddress>> completionHandler,
PushBackHandler pushBackHandler)
Deprecated.
|
void |
TemporarySelectorWriter.write(Connection<SocketAddress> connection,
SocketAddress dstAddress,
WritableMessage message,
CompletionHandler<WriteResult<WritableMessage,SocketAddress>> completionHandler,
PushBackHandler pushBackHandler,
long timeout,
TimeUnit timeunit)
Method writes the
WritableMessage to the specific address. |
Modifier and Type | Class and Description |
---|---|
protected class |
TCPNIOServerConnection.RegisterAcceptedChannelCompletionHandler |
protected class |
UDPNIOTransport.RegisterChannelCompletionHandler |
Modifier and Type | Method and Description |
---|---|
protected void |
TCPNIOAsyncQueueReader.addRecord(Connection connection,
Buffer buffer,
CompletionHandler completionHandler,
Interceptor<ReadResult> interceptor) |
protected void |
UDPNIOAsyncQueueReader.addRecord(Connection connection,
Buffer buffer,
CompletionHandler completionHandler,
Interceptor<ReadResult> interceptor) |
protected void |
TCPNIOServerConnection.closeGracefully0(CompletionHandler<Closeable> completionHandler,
CloseReason closeReason) |
protected void |
UDPNIOServerConnection.closeGracefully0(CompletionHandler<Closeable> completionHandler,
CloseReason closeReason) |
void |
TCPNIOTransport.connect(SocketAddress remoteAddress,
CompletionHandler<Connection> completionHandler)
Creates, initializes and connects socket to the specific
SocketAddress and returns Connection , representing socket. |
void |
UDPNIOTransport.connect(SocketAddress remoteAddress,
CompletionHandler<Connection> completionHandler)
Creates, initializes and connects socket to the specific
SocketAddress and returns Connection , representing socket. |
void |
TCPNIOTransport.connect(SocketAddress remoteAddress,
SocketAddress localAddress,
CompletionHandler<Connection> completionHandler)
Creates, initializes socket, binds it to the specific local and remote
SocketAddress and returns Connection , representing socket. |
void |
UDPNIOTransport.connect(SocketAddress remoteAddress,
SocketAddress localAddress,
CompletionHandler<Connection> completionHandler)
Creates, initializes socket, binds it to the specific local and remote
SocketAddress and returns Connection , representing socket. |
void |
TCPNIOConnectorHandler.connect(SocketAddress remoteAddress,
SocketAddress localAddress,
CompletionHandler<Connection> completionHandler) |
void |
UDPNIOConnectorHandler.connect(SocketAddress remoteAddress,
SocketAddress localAddress,
CompletionHandler<Connection> completionHandler) |
protected FutureImpl<Connection> |
TCPNIOConnectorHandler.connectAsync(SocketAddress remoteAddress,
SocketAddress localAddress,
CompletionHandler<Connection> completionHandler,
boolean needFuture) |
protected FutureImpl<Connection> |
UDPNIOConnectorHandler.connectAsync(SocketAddress remoteAddress,
SocketAddress localAddress,
CompletionHandler<Connection> completionHandler,
boolean needFuture) |
protected void |
TCPNIOConnectorHandler.connectSync(SocketAddress remoteAddress,
SocketAddress localAddress,
CompletionHandler<Connection> completionHandler) |
protected void |
UDPNIOConnectorHandler.connectSync(SocketAddress remoteAddress,
SocketAddress localAddress,
CompletionHandler<Connection> completionHandler) |
GrizzlyFuture<Integer> |
DefaultStreamWriter.flush(CompletionHandler<Integer> completionHandler) |
protected GrizzlyFuture<Integer> |
DefaultStreamWriter.Output.flush0(Buffer buffer,
CompletionHandler<Integer> completionHandler) |
protected void |
DefaultStreamReader.Input.notifyCompleted(CompletionHandler<Integer> completionHandler) |
protected void |
DefaultStreamReader.Input.notifyFailure(CompletionHandler<Integer> completionHandler,
Throwable failure) |
protected static void |
TCPNIOConnectorHandler.onConnectedAsync(TCPNIOConnection connection,
CompletionHandler<Connection> completionHandler) |
protected void |
UDPNIOServerConnection.terminate0(CompletionHandler<Closeable> completionHandler,
CloseReason closeReason) |
protected void |
TCPNIOConnection.terminate0(CompletionHandler<Closeable> completionHandler,
CloseReason closeReason) |
void |
UDPNIOServerConnection.unbind(CompletionHandler<Closeable> completionHandler) |
protected void |
TCPNIOConnectorHandler.waitNIOFuture(FutureImpl<Connection> future,
CompletionHandler<Connection> completionHandler) |
protected void |
UDPNIOConnectorHandler.waitNIOFuture(FutureImpl<Connection> future,
CompletionHandler<Connection> completionHandler) |
Modifier and Type | Method and Description |
---|---|
void |
SpdyStream.close(CompletionHandler<Closeable> completionHandler)
Deprecated.
please use
SpdyStream.close() with the following GrizzlyFuture.addCompletionHandler(org.glassfish.grizzly.CompletionHandler) call |
protected void |
SessionOutputSink.writeDataDownStream(SpdyStream spdyStream,
SpdyFrame headerFrame,
Buffer data,
CompletionHandler<WriteResult> completionHandler,
MessageCloner<Buffer> messageCloner,
boolean isLast) |
protected <K> void |
SessionOutputSink.writeDownStream(K anyMessage,
CompletionHandler<WriteResult> completionHandler,
MessageCloner<Buffer> messageCloner) |
protected void |
SessionOutputSink.writeDownStream(SpdyFrame frame,
CompletionHandler<WriteResult> completionHandler) |
Modifier and Type | Class and Description |
---|---|
class |
ChunkedCompletionHandler |
Constructor and Description |
---|
ChunkedCompletionHandler(CompletionHandler<WriteResult> parentCompletionHandler) |
Modifier and Type | Class and Description |
---|---|
protected static class |
SSLStreamWriter.HandshakeCompletionHandler |
Modifier and Type | Method and Description |
---|---|
protected void |
SSLFilter.handshake(Connection<?> connection,
CompletionHandler<SSLEngine> completionHandler,
Object dstAddress,
SSLEngineConfigurator sslEngineConfigurator,
FilterChainContext context,
boolean forceBeginHandshake) |
void |
SSLFilter.handshake(Connection connection,
CompletionHandler<SSLEngine> completionHandler) |
void |
SSLFilter.handshake(Connection connection,
CompletionHandler<SSLEngine> completionHandler,
Object dstAddress) |
void |
SSLFilter.handshake(Connection connection,
CompletionHandler<SSLEngine> completionHandler,
Object dstAddress,
SSLEngineConfigurator sslEngineConfigurator) |
Future<SSLEngine> |
SSLStreamWriter.handshake(SSLStreamReader sslStreamReader,
SSLEngineConfigurator configurator,
CompletionHandler<SSLEngine> completionHandler) |
Constructor and Description |
---|
HandshakeCompletionHandler(FutureImpl<SSLEngine> future,
CompletionHandler<SSLEngine> completionHandler,
SSLEngine sslEngine) |
Modifier and Type | Class and Description |
---|---|
static class |
AbstractStreamWriter.DisposeBufferCompletionHandler |
class |
TransformerInput.TransformerCompletionHandler |
Modifier and Type | Field and Description |
---|---|
protected CompletionHandler<Integer> |
BufferedInput.completionHandler |
Modifier and Type | Method and Description |
---|---|
GrizzlyFuture<Integer> |
StreamWriter.close(CompletionHandler<Integer> completionHandler)
Close the
StreamWriter and make sure all data was flushed. |
GrizzlyFuture<Integer> |
StreamOutput.close(CompletionHandler<Integer> completionHandler) |
GrizzlyFuture<Integer> |
AbstractStreamWriter.close(CompletionHandler<Integer> completionHandler)
Close the
StreamWriter and make sure all data was flushed. |
GrizzlyFuture<Integer> |
Output.close(CompletionHandler<Integer> completionHandler)
Close the
StreamWriter and make sure all data was flushed. |
GrizzlyFuture<Integer> |
BufferedOutput.close(CompletionHandler<Integer> completionHandler) |
<E> GrizzlyFuture<E> |
StreamReader.decode(Transformer<Stream,E> decoder,
CompletionHandler<E> completionHandler)
Read and decode data from the StreamReader
|
<E> GrizzlyFuture<E> |
AbstractStreamReader.decode(Transformer<Stream,E> decoder,
CompletionHandler<E> completionHandler)
Read and decode data from the StreamReader
|
<E> GrizzlyFuture<Stream> |
StreamWriter.encode(Transformer<E,Buffer> encoder,
E object,
CompletionHandler<Stream> completionHandler) |
<E> GrizzlyFuture<Stream> |
AbstractStreamWriter.encode(Transformer<E,Buffer> encoder,
E object,
CompletionHandler<Stream> completionHandler) |
GrizzlyFuture<Integer> |
StreamWriter.flush(CompletionHandler<Integer> completionHandler)
Make sure that all data that has been written is
flushed from the stream to its destination.
|
GrizzlyFuture<Integer> |
StreamOutput.flush(CompletionHandler<Integer> completionHandler) |
GrizzlyFuture<Integer> |
AbstractStreamWriter.flush(CompletionHandler<Integer> completionHandler)
Cause the overflow handler to be called even if buffer is not full.
|
GrizzlyFuture<Integer> |
Output.flush(CompletionHandler<Integer> completionHandler)
Make sure that all data that has been written is
flushed from the stream to its destination.
|
GrizzlyFuture<Integer> |
BufferedOutput.flush(CompletionHandler<Integer> completionHandler) |
protected GrizzlyFuture<Integer> |
TransformerOutput.flush0(Buffer buffer,
CompletionHandler<Integer> completionHandler) |
protected abstract GrizzlyFuture<Integer> |
BufferedOutput.flush0(Buffer buffer,
CompletionHandler<Integer> completionHandler) |
GrizzlyFuture<Integer> |
StreamReader.notifyAvailable(int size,
CompletionHandler<Integer> completionHandler)
Method returns
Future , using which it's possible check if
StreamReader has required amount of bytes available
for reading reading. |
GrizzlyFuture<Integer> |
AbstractStreamReader.notifyAvailable(int size,
CompletionHandler<Integer> completionHandler)
Method returns
Future , using which it's possible check if
StreamReader has required amount of bytes available
for reading reading. |
protected void |
BufferedInput.notifyCompleted(CompletionHandler<Integer> completionHandler) |
GrizzlyFuture<Integer> |
Input.notifyCondition(Condition condition,
CompletionHandler<Integer> completionHandler) |
GrizzlyFuture<Integer> |
BufferedInput.notifyCondition(Condition condition,
CompletionHandler<Integer> completionHandler) |
GrizzlyFuture<Integer> |
StreamInput.notifyCondition(Condition condition,
CompletionHandler<Integer> completionHandler) |
GrizzlyFuture<Integer> |
StreamReader.notifyCondition(Condition condition,
CompletionHandler<Integer> completionHandler)
|
GrizzlyFuture<Integer> |
AbstractStreamReader.notifyCondition(Condition condition,
CompletionHandler<Integer> completionHandler)
|
protected void |
BufferedInput.notifyFailure(CompletionHandler<Integer> completionHandler,
Throwable failure) |
Modifier and Type | Class and Description |
---|---|
class |
CompletionHandlerAdapter<A,B> |
Modifier and Type | Method and Description |
---|---|
CompletionHandler<E> |
StateHolder.ConditionElement.getCompletionHandler() |
static <A,B> CompletionHandler<B> |
Futures.toAdaptedCompletionHandler(FutureImpl<A> future,
CompletionHandler<A> completionHandler,
GenericAdapter<B,A> adapter)
|
static <A,B> CompletionHandler<B> |
Futures.toAdaptedCompletionHandler(FutureImpl<A> future,
GenericAdapter<B,A> adapter)
Creates
CompletionHandler , which may serve as a bridge
for passed FutureImpl . |
static <R> CompletionHandler<R> |
Futures.toCompletionHandler(FutureImpl<R> future)
Creates
CompletionHandler , which may serve as a bridge for passed
FutureImpl . |
static <R> CompletionHandler<R> |
Futures.toCompletionHandler(FutureImpl<R> future,
CompletionHandler<R> completionHandler)
Creates
CompletionHandler , which may serve as a bridge for passed
FutureImpl and CompletionHandler objects. |
Modifier and Type | Method and Description |
---|---|
static <R> void |
Futures.notifyCancel(FutureImpl<R> future,
CompletionHandler completionHandler)
Complete passed
FutureImpl and CompletionHandler via
the cancellation notification. |
static <R> void |
Futures.notifyFailure(FutureImpl<R> future,
CompletionHandler completionHandler,
Throwable error)
Complete passed
FutureImpl and CompletionHandler using
the passed error |
static <R> void |
Futures.notifyResult(FutureImpl<R> future,
CompletionHandler<R> completionHandler,
R result)
Complete passed
FutureImpl and CompletionHandler using
the passed result object. |
Future<E> |
StateHolder.notifyWhenConditionMatchState(Condition condition,
CompletionHandler<E> completionHandler)
Register listener, which will be notified, when state will match the condition.
|
Future<E> |
StateHolder.notifyWhenStateIsEqual(E state,
CompletionHandler<E> completionHandler)
Register listener, which will be notified, when state will be equal to passed
one.
|
Future<E> |
StateHolder.notifyWhenStateIsNotEqual(E state,
CompletionHandler<E> completionHandler)
Register listener, which will be notified, when state will become not equal
to passed one.
|
static <A,B> CompletionHandler<B> |
Futures.toAdaptedCompletionHandler(FutureImpl<A> future,
CompletionHandler<A> completionHandler,
GenericAdapter<B,A> adapter)
|
static <R> CompletionHandler<R> |
Futures.toCompletionHandler(FutureImpl<R> future,
CompletionHandler<R> completionHandler)
Creates
CompletionHandler , which may serve as a bridge for passed
FutureImpl and CompletionHandler objects. |
Constructor and Description |
---|
CompletionHandlerAdapter(FutureImpl<A> future,
CompletionHandler<A> completionHandler) |
CompletionHandlerAdapter(FutureImpl<A> future,
CompletionHandler<A> completionHandler,
GenericAdapter<B,A> adapter) |
ConditionElement(Condition condition,
FutureImpl<E> future,
CompletionHandler<E> completionHandler) |
Modifier and Type | Class and Description |
---|---|
class |
FrameCompletionHandler |
Modifier and Type | Method and Description |
---|---|
GrizzlyFuture<DataFrame> |
ProtocolHandler.send(DataFrame frame,
CompletionHandler<DataFrame> completionHandler) |
Copyright © 2015 Oracle Corporation. All rights reserved.