Modifier and Type | Method and Description |
---|---|
GrizzlyFuture<Closeable> |
Connection.close()
Gracefully close the
Connection |
GrizzlyFuture<Closeable> |
Closeable.close()
Gracefully (if supported by the implementation) closes this stream and
releases any system resources associated with it.
|
GrizzlyFuture<Connection> |
AbstractSocketConnectorHandler.connect(SocketAddress remoteAddress) |
GrizzlyFuture<Connection> |
AbstractSocketConnectorHandler.connect(SocketAddress remoteAddress,
SocketAddress localAddress) |
GrizzlyFuture<Connection> |
AbstractSocketConnectorHandler.connect(String host,
int port) |
<M> GrizzlyFuture<ReadResult<M,L>> |
Readable.read()
Method reads data.
|
GrizzlyFuture<ReadResult<Buffer,L>> |
Reader.read(Connection<L> connection)
Method reads data.
|
GrizzlyFuture<ReadResult<Buffer,L>> |
AbstractReader.read(Connection<L> connection)
Method reads data.
|
GrizzlyFuture<ReadResult<Buffer,L>> |
Reader.read(Connection<L> connection,
Buffer buffer)
Method reads data to the buffer.
|
GrizzlyFuture<ReadResult<Buffer,L>> |
AbstractReader.read(Connection<L> connection,
Buffer buffer)
Method reads data to the buffer.
|
GrizzlyFuture<Transport> |
Transport.shutdown()
Gracefully stops the transport accepting new connections and allows
existing work to complete before finalizing the shutdown.
|
GrizzlyFuture<Transport> |
Transport.shutdown(long gracePeriod,
TimeUnit timeUnit)
Gracefully stops the transport accepting new connections and allows
existing work to complete before finalizing the shutdown.
|
GrizzlyFuture<Closeable> |
Connection.terminate()
Close the
Connection |
GrizzlyFuture<Closeable> |
Closeable.terminate()
Closes this stream and releases any system resources associated with it.
|
GrizzlyFuture<WriteResult<WritableMessage,L>> |
AbstractWriter.write(Connection<L> connection,
L dstAddress,
WritableMessage message)
Method writes the
WritableMessage to the specific address. |
GrizzlyFuture<WriteResult<WritableMessage,L>> |
Writer.write(Connection<L> connection,
L dstAddress,
WritableMessage message)
Method writes the
WritableMessage to the specific address. |
GrizzlyFuture<WriteResult<WritableMessage,L>> |
AbstractWriter.write(Connection<L> connection,
WritableMessage message)
Method writes the
WritableMessage . |
GrizzlyFuture<WriteResult<WritableMessage,L>> |
Writer.write(Connection<L> connection,
WritableMessage message)
Method writes the
WritableMessage . |
<M> GrizzlyFuture<WriteResult<M,L>> |
Writeable.write(M message)
Method writes the buffer.
|
Modifier and Type | Field and Description |
---|---|
GrizzlyFuture<Connection> |
SingleEndpointPool.ConnectTimeoutTask.connectFuture |
Modifier and Type | Method and Description |
---|---|
GrizzlyFuture<Connection> |
SingleEndpointPool.take()
Obtains a
Connection from the pool in non-blocking/asynchronous fashion. |
GrizzlyFuture<Connection> |
MultiEndpointPool.take(EndpointKey<E> endpointKey)
Obtains a
Connection to the specified endpoint from the pool in
non-blocking/asynchronous fashion. |
Constructor and Description |
---|
ConnectTimeoutTask(GrizzlyFuture<Connection> future) |
Modifier and Type | Method and Description |
---|---|
GrizzlyFuture<HttpServer> |
HttpServer.shutdown()
Gracefully shuts down the
HttpServer instance. |
GrizzlyFuture<NetworkListener> |
NetworkListener.shutdown()
Gracefully shuts down the listener.
|
GrizzlyFuture<HttpServer> |
HttpServer.shutdown(long gracePeriod,
TimeUnit timeUnit) |
GrizzlyFuture<NetworkListener> |
NetworkListener.shutdown(long gracePeriod,
TimeUnit timeUnit) |
Modifier and Type | Interface and Description |
---|---|
interface |
FutureImpl<R>
Future interface, which has full control over the state. |
Modifier and Type | Class and Description |
---|---|
class |
ReadyFutureImpl<R>
Future implementation with the specific unmodifiable result. |
class |
SafeFutureImpl<R>
Safe
FutureImpl implementation. |
class |
UnsafeFutureImpl<R>
Simple thread-unsafe
Future implementation. |
Modifier and Type | Method and Description |
---|---|
GrizzlyFuture<Closeable> |
NIOConnection.close() |
<M> GrizzlyFuture<ReadResult<M,SocketAddress>> |
NIOConnection.read() |
GrizzlyFuture<RegisterChannelResult> |
NIOChannelDistributor.registerChannelAsync(SelectableChannel channel) |
GrizzlyFuture<RegisterChannelResult> |
AbstractNIOConnectionDistributor.registerChannelAsync(SelectableChannel channel) |
GrizzlyFuture<RegisterChannelResult> |
NIOChannelDistributor.registerChannelAsync(SelectableChannel channel,
int interestOps) |
GrizzlyFuture<RegisterChannelResult> |
AbstractNIOConnectionDistributor.registerChannelAsync(SelectableChannel channel,
int interestOps) |
GrizzlyFuture<RegisterChannelResult> |
NIOChannelDistributor.registerChannelAsync(SelectableChannel channel,
int interestOps,
Object attachment) |
GrizzlyFuture<RegisterChannelResult> |
AbstractNIOConnectionDistributor.registerChannelAsync(SelectableChannel channel,
int interestOps,
Object attachment) |
GrizzlyFuture<Transport> |
NIOTransport.shutdown() |
GrizzlyFuture<Transport> |
NIOTransport.shutdown(long gracePeriod,
TimeUnit timeUnit)
Gracefully stops the transport accepting new connections and allows
existing work to complete before finalizing the shutdown.
|
GrizzlyFuture<Closeable> |
NIOConnection.terminate() |
<M> GrizzlyFuture<WriteResult<M,SocketAddress>> |
NIOConnection.write(M message) |
Modifier and Type | Method and Description |
---|---|
GrizzlyFuture<Connection> |
TCPNIOServerConnection.accept()
Accept a
Connection . |
protected GrizzlyFuture<Connection> |
TCPNIOServerConnection.acceptAsync()
Asynchronously accept a
Connection |
GrizzlyFuture<Connection> |
UDPNIOTransport.connect()
Creates non-connected UDP
Connection . |
GrizzlyFuture<Connection> |
UDPNIOConnectorHandler.connect()
Creates non-connected UDP
Connection . |
GrizzlyFuture<Connection> |
TCPNIOTransport.connect(SocketAddress remoteAddress)
Creates, initializes and connects socket to the specific
SocketAddress and returns Connection , representing socket. |
GrizzlyFuture<Connection> |
UDPNIOTransport.connect(SocketAddress remoteAddress)
Creates, initializes and connects socket to the specific
SocketAddress and returns Connection , representing socket. |
GrizzlyFuture<Connection> |
TCPNIOTransport.connect(SocketAddress remoteAddress,
SocketAddress localAddress)
Creates, initializes socket, binds it to the specific local and remote
SocketAddress and returns Connection , representing socket. |
GrizzlyFuture<Connection> |
UDPNIOTransport.connect(SocketAddress remoteAddress,
SocketAddress localAddress)
Creates, initializes socket, binds it to the specific local and remote
SocketAddress and returns Connection , representing socket. |
GrizzlyFuture<Connection> |
TCPNIOTransport.connect(String host,
int port)
Creates, initializes and connects socket to the specific remote host
and port and returns
Connection , representing socket. |
GrizzlyFuture<Connection> |
UDPNIOTransport.connect(String host,
int port)
Creates, initializes and connects socket to the specific remote host
and port and returns
Connection , representing socket. |
GrizzlyFuture<Integer> |
DefaultStreamWriter.flush(CompletionHandler<Integer> completionHandler) |
protected GrizzlyFuture<Integer> |
DefaultStreamWriter.Output.flush0(Buffer buffer,
CompletionHandler<Integer> completionHandler) |
Modifier and Type | Method and Description |
---|---|
GrizzlyFuture<Closeable> |
SpdyStream.close() |
GrizzlyFuture<Closeable> |
SpdyStream.terminate() |
Modifier and Type | Field and Description |
---|---|
protected static GrizzlyFuture<Integer> |
AbstractStreamWriter.ZERO_READY_FUTURE |
protected static GrizzlyFuture<Integer> |
BufferedOutput.ZERO_READY_FUTURE |
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)
Read and decode data from the StreamReader
|
<E> GrizzlyFuture<E> |
AbstractStreamReader.decode(Transformer<Stream,E> decoder)
Read and decode data from the StreamReader
|
<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) |
<E> GrizzlyFuture<Stream> |
AbstractStreamWriter.encode(Transformer<E,Buffer> encoder,
E object) |
<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()
Make sure that all data that has been written is
flushed from the stream to its destination.
|
GrizzlyFuture<Integer> |
AbstractStreamWriter.flush()
Cause the overflow handler to be called even if buffer is not full.
|
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)
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)
Method returns
Future , using which it's possible check if
StreamReader has required amount of bytes available
for reading reading. |
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. |
GrizzlyFuture<Integer> |
StreamReader.notifyCondition(Condition condition)
|
GrizzlyFuture<Integer> |
AbstractStreamReader.notifyCondition(Condition condition)
|
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)
|
Modifier and Type | Method and Description |
---|---|
static <R> GrizzlyFuture<R> |
Futures.createReadyFuture(R result)
Create a
Future , which has a preset result. |
static <R> GrizzlyFuture<R> |
Futures.createReadyFuture(Throwable error)
Create a
Future , which has a preset failure. |
Modifier and Type | Method and Description |
---|---|
GrizzlyFuture<DataFrame> |
ProtocolHandler.close(int code,
String reason) |
GrizzlyFuture<DataFrame> |
SimpleWebSocket.send(byte[] data) |
GrizzlyFuture<DataFrame> |
ProtocolHandler.send(byte[] data) |
GrizzlyFuture<DataFrame> |
WebSocket.send(byte[] data)
Send a binary frame to the remote end-point.
|
GrizzlyFuture<DataFrame> |
ProtocolHandler.send(DataFrame frame) |
GrizzlyFuture<DataFrame> |
ProtocolHandler.send(DataFrame frame,
CompletionHandler<DataFrame> completionHandler) |
GrizzlyFuture<DataFrame> |
SimpleWebSocket.send(String data) |
GrizzlyFuture<DataFrame> |
ProtocolHandler.send(String data) |
GrizzlyFuture<DataFrame> |
WebSocket.send(String data)
Send a text frame to the remote end-point.
|
GrizzlyFuture<DataFrame> |
SimpleWebSocket.sendPing(byte[] data)
Sends a
ping frame with the specified payload (if any). |
GrizzlyFuture<DataFrame> |
WebSocket.sendPing(byte[] data)
Sends a
ping frame with the specified payload (if any). |
GrizzlyFuture<DataFrame> |
SimpleWebSocket.sendPong(byte[] data)
Sends a
ping frame with the specified payload (if any). |
GrizzlyFuture<DataFrame> |
WebSocket.sendPong(byte[] data)
Sends a
ping frame with the specified payload (if any). |
GrizzlyFuture<DataFrame> |
SimpleWebSocket.stream(boolean last,
byte[] bytes,
int off,
int len) |
GrizzlyFuture<DataFrame> |
ProtocolHandler.stream(boolean last,
byte[] bytes,
int off,
int len) |
GrizzlyFuture<DataFrame> |
WebSocket.stream(boolean last,
byte[] fragment,
int off,
int len)
Sends a fragment of a complete message.
|
GrizzlyFuture<DataFrame> |
SimpleWebSocket.stream(boolean last,
String fragment) |
GrizzlyFuture<DataFrame> |
ProtocolHandler.stream(boolean last,
String fragment) |
GrizzlyFuture<DataFrame> |
WebSocket.stream(boolean last,
String fragment)
Sends a fragment of a complete message.
|
Copyright © 2015 Oracle Corporation. All rights reserved.