org.argeo.util

Class ServiceChannel

java.lang.Object

org.argeo.util.ServiceChannel

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, java.nio.channels.AsynchronousByteChannel, java.nio.channels.AsynchronousChannel, java.nio.channels.Channel

public class ServiceChannel
extends java.lang.Object
implements java.nio.channels.AsynchronousByteChannel

An AsynchronousByteChannel based on an ExecutorService.

Constructor Summary

Constructors

Constructor and Description
ServiceChannel(java.nio.channels.ReadableByteChannel in, java.nio.channels.WritableByteChannel out, java.util.concurrent.ExecutorService executor)

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	isOpen()
java.util.concurrent.Future<java.lang.Integer>	read(java.nio.ByteBuffer dst)
<A> void	read(java.nio.ByteBuffer dst, A attachment, java.nio.channels.CompletionHandler<java.lang.Integer,? super A> handler)
java.util.concurrent.Future<java.lang.Integer>	write(java.nio.ByteBuffer src)
<A> void	write(java.nio.ByteBuffer src, A attachment, java.nio.channels.CompletionHandler<java.lang.Integer,? super A> handler)

Methods inherited from class java.lang.Object

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

Constructor Detail

ServiceChannel

public ServiceChannel(java.nio.channels.ReadableByteChannel in,
                      java.nio.channels.WritableByteChannel out,
                      java.util.concurrent.ExecutorService executor)

Method Detail

read

public java.util.concurrent.Future<java.lang.Integer> read(java.nio.ByteBuffer dst)

Specified by:

read in interface java.nio.channels.AsynchronousByteChannel

read

public <A> void read(java.nio.ByteBuffer dst,
                     A attachment,
                     java.nio.channels.CompletionHandler<java.lang.Integer,? super A> handler)

Specified by:

read in interface java.nio.channels.AsynchronousByteChannel

write

public java.util.concurrent.Future<java.lang.Integer> write(java.nio.ByteBuffer src)

Specified by:

write in interface java.nio.channels.AsynchronousByteChannel

write

public <A> void write(java.nio.ByteBuffer src,
                      A attachment,
                      java.nio.channels.CompletionHandler<java.lang.Integer,? super A> handler)

Specified by:

write in interface java.nio.channels.AsynchronousByteChannel

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.nio.channels.AsynchronousChannel

Specified by:

close in interface java.nio.channels.Channel

Throws:

java.io.IOException

isOpen

public boolean isOpen()

Specified by:

isOpen in interface java.nio.channels.Channel