Module org.xbib.rpm

Package org.xbib.rpm.io

Class WritableChannelWrapper

java.lang.Object

org.xbib.rpm.io.ChannelWrapper

org.xbib.rpm.io.WritableChannelWrapper

All Implemented Interfaces:

Closeable, AutoCloseable, Channel, WritableByteChannel

public class WritableChannelWrapper
extends ChannelWrapper
implements WritableByteChannel

Wrapper around a writable channel that allows for observing written data.

Nested Class Summary

Nested classes/interfaces inherited from class org.xbib.rpm.io.ChannelWrapper

ChannelWrapper.Consumer<T>, ChannelWrapper.Key<T>

Field Summary

Fields

Modifier and Type	Field	Description
protected WritableByteChannel	channel

Constructor Summary

Constructors

Constructor	Description
WritableChannelWrapper(WritableByteChannel channel)

Method Summary

Modifier and Type	Method	Description
void	close()	Closes the underlying channel and completes any outstanding operations in the consumers.
boolean	isOpen()	Flag indicating whether the underlying channel is open.
int	write(ByteBuffer buffer)	Writes data to the wrapped channel, while passing an exact copy to the registered consumers.

Methods inherited from class org.xbib.rpm.io.ChannelWrapper

empty, fill, fill, finish, startCount, startCount

Methods inherited from class java.lang.Object

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

Field Details

channel

protected WritableByteChannel channel

Constructor Details

WritableChannelWrapper

public WritableChannelWrapper(WritableByteChannel channel)

Method Details

write

public int write(ByteBuffer buffer)
          throws IOException

Writes data to the wrapped channel, while passing an exact copy to the registered consumers.

Specified by:

write in interface WritableByteChannel

Parameters:

buffer - the buffer to write to the wrapped channel

Returns:

the number of bytes written

Throws:

IOException - if an IO error occurs

close

public void close()
           throws IOException

Closes the underlying channel and completes any outstanding operations in the consumers.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Channel

Specified by:

close in interface Closeable

Overrides:

close in class ChannelWrapper

Throws:

IOException - if an IO error occurs

isOpen

public boolean isOpen()

Flag indicating whether the underlying channel is open.

Specified by:

isOpen in interface Channel

Returns:

true if it is open, false otherwise