|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object net.sf.asyncobjects.AsyncUnicastServer<T> net.sf.asyncobjects.net.nio.NIOStream<T>
T
- input or output streampublic abstract class NIOStream<T extends ACloseable>
Base class for NIO Streams. The class implemetns common initalization logic.
Field Summary | |
---|---|
protected boolean |
isClosed
if true the stream is considered to be closed |
Method Summary | |
---|---|
void |
awake()
awake signal |
Promise<Void> |
close()
Close stream |
protected void |
ensureOpen()
Ensure that stream is open |
protected ByteBuffer |
getDirectBuffer()
|
protected void |
returnDirectBuffer(ByteBuffer buffer)
Return buffer to the runner |
protected abstract void |
shutdownStream()
Shutdown 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 |
Field Detail |
---|
protected boolean isClosed
Method Detail |
---|
public void awake()
protected abstract void shutdownStream() throws IOException
IOException
- if there is a problem with shutdowingpublic Promise<Void> close()
close
in interface ACloseable
protected void ensureOpen()
protected ByteBuffer getDirectBuffer()
protected void returnDirectBuffer(ByteBuffer buffer)
buffer
- a buffer to return
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |