Package org.bluezoo.util

Class BufferingByteChannel

java.lang.Object

org.bluezoo.util.BufferingByteChannel

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable, Channel, WritableByteChannel

public class BufferingByteChannel
extends Object
implements WritableByteChannel, Flushable

A WritableByteChannel decorator that buffers writes into a fixed-size ByteBuffer before flushing to the underlying channel.

This reduces the number of blocking I/O syscalls when writing to file-backed channels by accumulating small writes and flushing them as larger chunks. The buffer is flushed automatically when full, or explicitly via flush().

This is a pure NIO implementation with no InputStream or OutputStream involvement.

Author:

Chris Burdess

Constructor Summary

Constructors

Constructor	Description
BufferingByteChannel(WritableByteChannel delegate, int bufferSize)	Creates a buffering channel that wraps the given delegate.

Method Summary

Modifier and Type	Method	Description
void	close()
void	flush()
boolean	isOpen()
int	write(ByteBuffer src)

Methods inherited from class java.lang.Object

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

Constructor Details

BufferingByteChannel

public BufferingByteChannel(WritableByteChannel delegate,
 int bufferSize)

Creates a buffering channel that wraps the given delegate.

Parameters:

delegate - the underlying channel to write to

bufferSize - the buffer size in bytes

Method Details

write

public int write(ByteBuffer src)
          throws IOException

Specified by:

write in interface WritableByteChannel

Throws:

IOException

flush

public void flush()
           throws IOException

Specified by:

flush in interface Flushable

Throws:

IOException

isOpen

public boolean isOpen()

Specified by:

isOpen in interface Channel

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Channel

Specified by:

close in interface Closeable

Throws:

IOException