com.prosysopc.ua.stack.utils.asyncsocket

Class AsyncSocketImpl.AsyncSocketOutputStream

java.lang.Object

com.prosysopc.ua.stack.utils.asyncsocket.AsyncOutputStream

com.prosysopc.ua.stack.utils.asyncsocket.AsyncSocketImpl.AsyncSocketOutputStream

Enclosing class:

AsyncSocketImpl

public class AsyncSocketImpl.AsyncSocketOutputStream
extends AsyncOutputStream

Internal AsyncOutputStream of the AsyncSocketImpl.

Constructor Summary

Constructors

Constructor and Description
AsyncSocketOutputStream()

Method Summary

Modifier and Type	Method and Description
void	close()
BufferMonitor	createMonitor(long position, MonitorListener listener) Create an object that monitors for flush position of the output stream.
void	flush()
long	getFlushPosition() Get the position of stream that has been flushed.
long	getPosition() Get the position of the stream
long	getUnflushedBytes() Get number of bytes remaining to be written
void	offer(ByteBuffer buf) Offers byte buffer to the output stream for write.
void	write(byte[] b, int off, int len)
void	write(ByteBuffer src) Write to stream
void	write(ByteBuffer src, int length) Write to stream
void	write(int b)

Methods inherited from class java.lang.Object

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

Constructor Detail

AsyncSocketOutputStream

public AsyncSocketOutputStream()

Method Detail

close

public void close()

createMonitor

public BufferMonitor createMonitor(long position,
                                   MonitorListener listener)

Description copied from class: AsyncOutputStream

Create an object that monitors for flush position of the output stream.

Specified by:

createMonitor in class AsyncOutputStream

Parameters:

position - position to trigger

listener - alarm listener

Returns:

alarm

flush

public void flush()
           throws IOException

Throws:

IOException

getFlushPosition

public long getFlushPosition()

Description copied from class: AsyncOutputStream

Get the position of stream that has been flushed. This position lags behind getPosition() value

Specified by:

getFlushPosition in class AsyncOutputStream

Returns:

bytes flushed from the stream

getPosition

public long getPosition()

Description copied from class: AsyncOutputStream

Get the position of the stream

Specified by:

getPosition in class AsyncOutputStream

Returns:

number of bytes written to the stream

getUnflushedBytes

public long getUnflushedBytes()

Description copied from class: AsyncOutputStream

Get number of bytes remaining to be written

Specified by:

getUnflushedBytes in class AsyncOutputStream

Returns:

the number of unflushed bytes

offer

public void offer(ByteBuffer buf)

Description copied from class: AsyncOutputStream

Offers byte buffer to the output stream for write. The ownership of the byte buffer and its back-end will be taken over by the stream.

Specified by:

offer in class AsyncOutputStream

Parameters:

buf - buffer to offer

write

public void write(byte[] b,
                  int off,
                  int len)
           throws IOException

Throws:

IOException

write

public void write(ByteBuffer src)

Description copied from class: AsyncOutputStream

Write to stream

Specified by:

write in class AsyncOutputStream

Parameters:

src - a ByteBuffer object.

write

public void write(ByteBuffer src,
                  int length)

Description copied from class: AsyncOutputStream

Write to stream

Specified by:

write in class AsyncOutputStream

Parameters:

src - a ByteBuffer object.

length - a int.

write

public void write(int b)
           throws IOException

Throws:

IOException