|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Packages that use IoFuture | |
|---|---|
| com.sun.sgs.impl.nio | Implements asynchronous IO as specified by
the package com.sun.sgs.nio.channels. |
| com.sun.sgs.impl.protocol.simple | Provides an implementation of the protocol layer APIs using the
SimpleSgsProtocol. |
| com.sun.sgs.impl.transport.tcp | Provides an implementation of the transport layer APIs using TCP. |
| com.sun.sgs.nio.channels | Defines asynchronous channels that are connected to a stream-oriented connecting or listening socket, or a datagram-oriented socket. |
| Uses of IoFuture in com.sun.sgs.impl.nio |
|---|
| Classes in com.sun.sgs.impl.nio that implement IoFuture | |
|---|---|
class |
AttachedFuture<R,A>
An implementation of IoFuture that adds an object attachment
to an arbitrary Future. |
class |
DelegatingCompletionHandler<OR,OA,IR,IA>
An abstract base class for defining a CompletionHandler to use when
implementing methods that return an IoFuture, have a CompletionHandler parameter, and are implemented by making calls to similar
methods. |
class |
IoFutureTask<R,A>
An implementation of IoFuture that adds an object attachment to a
FutureTask. |
| Methods in com.sun.sgs.impl.nio that return IoFuture | ||
|---|---|---|
|
AsyncServerSocketChannelImpl.accept(A attachment,
CompletionHandler<AsynchronousSocketChannel,? super A> handler)
Accepts a connection. |
|
|
AsyncDatagramChannelImpl.connect(SocketAddress remote,
A attachment,
CompletionHandler<Void,? super A> handler)
Connects this channel. |
|
|
AsyncSocketChannelImpl.connect(SocketAddress remote,
A attachment,
CompletionHandler<Void,? super A> handler)
Connects this channel. |
|
|
AsyncDatagramChannelImpl.disconnect(A attachment,
CompletionHandler<Void,? super A> handler)
Disconnects this channel. |
|
(package private)
|
Reactor.PendingOperation.execute(A attachment,
CompletionHandler<R,? super A> handler,
long timeout,
TimeUnit unit,
Callable<R> callable)
Attempts to initiate an asynchronous operation. |
|
|
AsyncKey.execute(int op,
A attachment,
CompletionHandler<R,? super A> handler,
long timeout,
TimeUnit unit,
Callable<R> callable)
Initiates the given operation asynchronously on the underlying channel, and returns a future representing the result. |
|
|
Reactor.ReactiveAsyncKey.execute(int op,
A attachment,
CompletionHandler<R,? super A> handler,
long timeout,
TimeUnit unit,
Callable<R> callable)
Initiates the given operation asynchronously on the underlying channel, and returns a future representing the result. |
|
protected abstract IoFuture<IR,IA> |
DelegatingCompletionHandler.implCompleted(IoFuture<IR,IA> innerResult)
Called when the delegated computation completes. |
|
protected abstract IoFuture<IR,IA> |
DelegatingCompletionHandler.implStart()
Starts the computation, returning a future for managing the inner computation or null to indicate that the computation is
completed. |
|
static
|
IoFutureTask.newInstance(Callable<R> callable,
A attachment)
Creates an instance of this class for running the specified Callable and including the specified attachment. |
|
|
AsyncSocketChannelImpl.read(ByteBuffer[] dsts,
int offset,
int length,
long timeout,
TimeUnit unit,
A attachment,
CompletionHandler<Long,? super A> handler)
Reads a sequence of bytes from this channel into a subsequence of the given buffers. |
|
|
AsyncDatagramChannelImpl.read(ByteBuffer dst,
long timeout,
TimeUnit unit,
A attachment,
CompletionHandler<Integer,? super A> handler)
Receives a datagram via this channel. |
|
|
AsyncSocketChannelImpl.read(ByteBuffer dst,
long timeout,
TimeUnit unit,
A attachment,
CompletionHandler<Integer,? super A> handler)
Reads a sequence of bytes from this channel into the given buffer. |
|
|
AsyncDatagramChannelImpl.receive(ByteBuffer dst,
long timeout,
TimeUnit unit,
A attachment,
CompletionHandler<SocketAddress,? super A> handler)
Receives a datagram via this channel. |
|
|
AsyncDatagramChannelImpl.send(ByteBuffer src,
SocketAddress target,
long timeout,
TimeUnit unit,
A attachment,
CompletionHandler<Integer,? super A> handler)
Sends a datagram via this channel. |
|
IoFuture<OR,OA> |
DelegatingCompletionHandler.start()
Starts the computation and returns a future representing the result of the computation. |
|
|
AsyncSocketChannelImpl.write(ByteBuffer[] srcs,
int offset,
int length,
long timeout,
TimeUnit unit,
A attachment,
CompletionHandler<Long,? super A> handler)
Writes a sequence of bytes to this channel from a subsequence of the given buffers. |
|
|
AsyncDatagramChannelImpl.write(ByteBuffer src,
long timeout,
TimeUnit unit,
A attachment,
CompletionHandler<Integer,? super A> handler)
Writes a datagram to this channel. |
|
|
AsyncSocketChannelImpl.write(ByteBuffer src,
long timeout,
TimeUnit unit,
A attachment,
CompletionHandler<Integer,? super A> handler)
Writes a sequence of bytes to this channel from the given buffer. |
|
| Methods in com.sun.sgs.impl.nio with parameters of type IoFuture | |
|---|---|
void |
DelegatingCompletionHandler.completed(IoFuture<IR,IA> innerResult)
Invoked when an inner computation has completed. |
protected abstract IoFuture<IR,IA> |
DelegatingCompletionHandler.implCompleted(IoFuture<IR,IA> innerResult)
Called when the delegated computation completes. |
| Uses of IoFuture in com.sun.sgs.impl.protocol.simple |
|---|
| Methods in com.sun.sgs.impl.protocol.simple that return IoFuture | |
|---|---|
IoFuture<ByteBuffer,Void> |
AsynchronousMessageChannel.read(CompletionHandler<ByteBuffer,Void> handler)
Initiates reading a complete message from this channel. |
IoFuture<Void,Void> |
AsynchronousMessageChannel.write(ByteBuffer src,
CompletionHandler<Void,Void> handler)
Initiates writing a complete message from the given buffer to the underlying channel, and returns a future for controlling the operation. |
| Uses of IoFuture in com.sun.sgs.impl.transport.tcp |
|---|
| Fields in com.sun.sgs.impl.transport.tcp declared as IoFuture | |
|---|---|
(package private) IoFuture<?,?> |
TcpTransport.acceptFuture
The currently-active accept operation, or null if none. |
| Uses of IoFuture in com.sun.sgs.nio.channels |
|---|
| Methods in com.sun.sgs.nio.channels that return IoFuture | ||
|---|---|---|
abstract
|
AsynchronousServerSocketChannel.accept(A attachment,
CompletionHandler<AsynchronousSocketChannel,? super A> handler)
Accepts a connection. |
|
|
AsynchronousServerSocketChannel.accept(CompletionHandler<AsynchronousSocketChannel,? super A> handler)
Accepts a connection. |
|
abstract
|
AsynchronousSocketChannel.connect(SocketAddress remote,
A attachment,
CompletionHandler<Void,? super A> handler)
Connects this channel. |
|
abstract
|
AsynchronousDatagramChannel.connect(SocketAddress remote,
A attachment,
CompletionHandler<Void,? super A> handler)
Connects this channel. |
|
|
AsynchronousSocketChannel.connect(SocketAddress remote,
CompletionHandler<Void,? super A> handler)
Connects this channel. |
|
|
AsynchronousDatagramChannel.connect(SocketAddress remote,
CompletionHandler<Void,? super A> handler)
Connects this channel. |
|
abstract
|
AsynchronousDatagramChannel.disconnect(A attachment,
CompletionHandler<Void,? super A> handler)
Disconnects this channel. |
|
|
AsynchronousDatagramChannel.disconnect(CompletionHandler<Void,? super A> handler)
Disconnects this channel. |
|
abstract
|
AsynchronousSocketChannel.read(ByteBuffer[] dsts,
int offset,
int length,
long timeout,
TimeUnit unit,
A attachment,
CompletionHandler<Long,? super A> handler)
Reads a sequence of bytes from this channel into a subsequence of the given buffers. |
|
|
AsynchronousSocketChannel.read(ByteBuffer dst,
A attachment,
CompletionHandler<Integer,? super A> handler)
Reads a sequence of bytes from this channel into the given buffer. |
|
|
AsynchronousDatagramChannel.read(ByteBuffer dst,
A attachment,
CompletionHandler<Integer,? super A> handler)
Receives a datagram via this channel. |
|
|
AsynchronousByteChannel.read(ByteBuffer dst,
A attachment,
CompletionHandler<Integer,? super A> handler)
Reads a sequence of bytes from this channel into the given buffer. |
|
|
AsynchronousSocketChannel.read(ByteBuffer dst,
CompletionHandler<Integer,? super A> handler)
Reads a sequence of bytes from this channel into the given buffer. |
|
|
AsynchronousDatagramChannel.read(ByteBuffer dst,
CompletionHandler<Integer,? super A> handler)
Receives a datagram via this channel. |
|
|
AsynchronousByteChannel.read(ByteBuffer dst,
CompletionHandler<Integer,? super A> handler)
Reads a sequence of bytes from this channel into the given buffer. |
|
abstract
|
AsynchronousSocketChannel.read(ByteBuffer dst,
long timeout,
TimeUnit unit,
A attachment,
CompletionHandler<Integer,? super A> handler)
Reads a sequence of bytes from this channel into the given buffer. |
|
abstract
|
AsynchronousDatagramChannel.read(ByteBuffer dst,
long timeout,
TimeUnit unit,
A attachment,
CompletionHandler<Integer,? super A> handler)
Receives a datagram via this channel. |
|
|
AsynchronousDatagramChannel.receive(ByteBuffer dst,
A attachment,
CompletionHandler<SocketAddress,? super A> handler)
Receives a datagram via this channel. |
|
|
AsynchronousDatagramChannel.receive(ByteBuffer dst,
CompletionHandler<SocketAddress,? super A> handler)
Receives a datagram via this channel. |
|
abstract
|
AsynchronousDatagramChannel.receive(ByteBuffer dst,
long timeout,
TimeUnit unit,
A attachment,
CompletionHandler<SocketAddress,? super A> handler)
Receives a datagram via this channel. |
|
|
AsynchronousDatagramChannel.send(ByteBuffer src,
SocketAddress target,
A attachment,
CompletionHandler<Integer,? super A> handler)
Sends a datagram via this channel. |
|
|
AsynchronousDatagramChannel.send(ByteBuffer src,
SocketAddress target,
CompletionHandler<Integer,? super A> handler)
Sends a datagram via this channel. |
|
abstract
|
AsynchronousDatagramChannel.send(ByteBuffer src,
SocketAddress target,
long timeout,
TimeUnit unit,
A attachment,
CompletionHandler<Integer,? super A> handler)
Sends a datagram via this channel. |
|
abstract
|
AsynchronousSocketChannel.write(ByteBuffer[] srcs,
int offset,
int length,
long timeout,
TimeUnit unit,
A attachment,
CompletionHandler<Long,? super A> handler)
Writes a sequence of bytes to this channel from a subsequence of the given buffers. |
|
|
AsynchronousSocketChannel.write(ByteBuffer src,
A attachment,
CompletionHandler<Integer,? super A> handler)
Writes a sequence of bytes to this channel from the given buffer. |
|
|
AsynchronousDatagramChannel.write(ByteBuffer src,
A attachment,
CompletionHandler<Integer,? super A> handler)
Writes a datagram to this channel. |
|
|
AsynchronousByteChannel.write(ByteBuffer src,
A attachment,
CompletionHandler<Integer,? super A> handler)
Writes a sequence of bytes to this channel from the given buffer. |
|
|
AsynchronousSocketChannel.write(ByteBuffer src,
CompletionHandler<Integer,? super A> handler)
Writes a sequence of bytes to this channel from the given buffer. |
|
|
AsynchronousDatagramChannel.write(ByteBuffer src,
CompletionHandler<Integer,? super A> handler)
Writes a datagram to this channel. |
|
|
AsynchronousByteChannel.write(ByteBuffer src,
CompletionHandler<Integer,? super A> handler)
Writes a sequence of bytes to this channel from the given buffer. |
|
abstract
|
AsynchronousSocketChannel.write(ByteBuffer src,
long timeout,
TimeUnit unit,
A attachment,
CompletionHandler<Integer,? super A> handler)
Writes a sequence of bytes to this channel from the given buffer. |
|
abstract
|
AsynchronousDatagramChannel.write(ByteBuffer src,
long timeout,
TimeUnit unit,
A attachment,
CompletionHandler<Integer,? super A> handler)
Writes a datagram to this channel. |
|
| Methods in com.sun.sgs.nio.channels with parameters of type IoFuture | |
|---|---|
void |
CompletionHandler.completed(IoFuture<R,A> result)
Invoked when an operation has completed. |
|
RedDwarf, Version 0.10.1 2010-03-14 10:56:12 |
|||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||