net.sf.asyncobjects.io.adapters
Class OutputStreamAdapter

java.lang.Object
  net.sf.asyncobjects.AsyncUnicastServer<AByteOutput>
      net.sf.asyncobjects.io.adapters.OutputStreamAdapter

All Implemented Interfaces:

ACloseable, AsyncObject, ExplicitSharing, AByteOutput, AOutput<BinaryData>

Direct Known Subclasses:

TSocket.TOutputStreamAdapter

public class OutputStreamAdapter
extends AsyncUnicastServer<AByteOutput>
implements AByteOutput

An adapter for output stream

Author:

const

Constructor Summary

OutputStreamAdapter(OutputStream out)
A constructor

OutputStreamAdapter(OutputStream out, int bufferSize)
A constructor

Method Summary

Promise<Void>	close() close stream
Promise<Void>	flush() Flush output
Promise<Void>	write(BinaryData data) Write data to stream

Methods inherited from class net.sf.asyncobjects.AsyncUnicastServer

dereference, export, isImmediate, myVat, promise

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface net.sf.asyncobjects.AsyncObject

dereference, isImmediate

Constructor Detail

OutputStreamAdapter

public OutputStreamAdapter(OutputStream out)

A constructor

Parameters:

out - wrapped output stream

OutputStreamAdapter

public OutputStreamAdapter(OutputStream out,
                           int bufferSize)

A constructor

Parameters:

out - wrapped ouput stream

bufferSize - a buffer size

Method Detail

write

public Promise<Void> write(BinaryData data)

Write data to stream

Specified by:

write in interface AOutput<BinaryData>

Parameters:

data - a data to write

Returns:

a promise that resolves when pipe is ready for further writing

See Also:

AOutput.write(net.sf.asyncobjects.io.BatchedData)

flush

public Promise<Void> flush()

Flush output

Specified by:

flush in interface AOutput<BinaryData>

Returns:

a promise that will resolve when data will be written out

See Also:

AOutput.flush()

close

public Promise<Void> close()

close stream

Specified by:

close in interface ACloseable

Returns:

a promise that resolves when object is closed.

See Also:

ACloseable.close()