Uses of Interface
org.ogf.saga.stream.Stream

Packages that use Stream

Package	Description
org.ogf.saga.stream	The streams package provides a simple mechanism for setting up connections to remote components.

Uses of Stream in org.ogf.saga.stream

Methods in org.ogf.saga.stream that return Stream

Modifier and Type	Method and Description
Stream	StreamServer.connect() Establishes a connection to the stream server.
Stream	StreamServer.connect(float timeoutInSeconds) Establishes a connection to the stream server.
static Stream	StreamFactory.createStream(Session session, URL name) Creates a Stream.
static Stream	StreamFactory.createStream(String sagaFactoryClassname, Session session, URL name) Creates a Stream.
static Stream	StreamFactory.createStream(String sagaFactoryClassname, URL name) Creates a Stream using the default session.
static Stream	StreamFactory.createStream(URL name) Creates a Stream using the default session.
protected abstract Stream	StreamFactory.doCreateStream(Session session, URL name) Creates a Stream.
Stream	StreamServer.serve() Waits for incoming client connections (like an accept of a serversocket).
Stream	StreamServer.serve(float timeoutInSeconds) Waits for incoming client connections (like an accept of a serversocket).

Methods in org.ogf.saga.stream that return types with arguments of type Stream

Modifier and Type	Method and Description
Task<Stream,Void>	Stream.close(TaskMode mode) Returns a task that closes an active connection.
Task<Stream,Void>	Stream.close(TaskMode mode, float timeoutInSeconds) Returns a task that closes an active connection.
Task<StreamServer,Stream>	StreamServer.connect(TaskMode mode) Returns a task that establishes a connection to the stream server.
Task<Stream,Void>	Stream.connect(TaskMode mode) Returns a task that establishes a connection to the target defined during the construction of the stream.
Task<StreamServer,Stream>	StreamServer.connect(TaskMode mode, float timeoutInSeconds) Returns a task that establishes a connection to the stream server.
Task<Stream,Void>	Stream.connect(TaskMode mode, float timeoutInSeconds) Returns a task that establishes a connection to the target defined during the construction of the stream.
static Task<StreamFactory,Stream>	StreamFactory.createStream(String sagaFactoryClassname, TaskMode mode, Session session, URL name) Creates a task that creates a Stream.
static Task<StreamFactory,Stream>	StreamFactory.createStream(String sagaFactoryClassname, TaskMode mode, URL name) Creates a task that creates a Stream using the default session.
static Task<StreamFactory,Stream>	StreamFactory.createStream(TaskMode mode, Session session, URL name) Creates a task that creates a Stream.
static Task<StreamFactory,Stream>	StreamFactory.createStream(TaskMode mode, URL name) Creates a task that creates a Stream using the default session.
protected abstract Task<StreamFactory,Stream>	StreamFactory.doCreateStream(TaskMode mode, Session session, URL name) Creates a task that creates a Stream.
Task<Stream,Context>	Stream.getContext(TaskMode mode) Creates a task that obtains the remote authorization info.
Task<Stream,StreamInputStream>	Stream.getInputStream(TaskMode mode) Creates a task that obtains an OutputStream from the stream.
Task<Stream,StreamOutputStream>	Stream.getOutputStream(TaskMode mode) Creates a task that obtains an OutputStream from the stream.
Task<Stream,URL>	Stream.getUrl(TaskMode mode) Creates a task that obtains the URL that was used to create the stream.
Task<Stream,Integer>	Stream.read(TaskMode mode, Buffer buffer) Creates a task that reads a raw buffer from the stream.
Task<Stream,Integer>	Stream.read(TaskMode mode, Buffer buffer, int len) Creates a task that reads a raw buffer from the stream.
Task<StreamServer,Stream>	StreamServer.serve(TaskMode mode) Obtains a task that waits for incoming client connections (like an accept of a serversocket).
Task<StreamServer,Stream>	StreamServer.serve(TaskMode mode, float timeoutInSeconds) Obtains a task that waits for incoming client connections (like an accept of a serversocket).
Task<Stream,Integer>	Stream.waitFor(TaskMode mode, int what) Returns a task that checks if the stream is ready for I/O, or if it has entered the ERROR state.
Task<Stream,Integer>	Stream.waitFor(TaskMode mode, int what, float timeoutInSeconds) Returns a task that checks if the stream is ready for I/O, or if it has entered the ERROR state.
Task<Stream,Integer>	Stream.write(TaskMode mode, Buffer buffer) Creates a task that writes a raw buffer to the stream.
Task<Stream,Integer>	Stream.write(TaskMode mode, Buffer buffer, int len) Creates a task that writes a raw buffer to the stream.