Package jadex.bridge.component.streams
Class LocalOutputConnectionHandler
- java.lang.Object
- 
- jadex.bridge.component.streams.LocalAbstractConnectionHandler
- 
- jadex.bridge.component.streams.LocalOutputConnectionHandler
 
 
- 
- All Implemented Interfaces:
- IAbstractConnectionHandler,- IOutputConnectionHandler
 
 public class LocalOutputConnectionHandler extends LocalAbstractConnectionHandler implements IOutputConnectionHandler 
- 
- 
Field SummaryFields Modifier and Type Field Description protected intmaxstoredThe maximum bytes of data that can be stored in connection (without being consumed).protected Future<java.lang.Integer>readyfutureThe ready future.- 
Fields inherited from class jadex.bridge.component.streams.LocalAbstractConnectionHandlercon, conhandler, nonfunc
 
- 
 - 
Constructor SummaryConstructors Constructor Description LocalOutputConnectionHandler(java.util.Map<java.lang.String,java.lang.Object> nonfunc)LocalOutputConnectionHandler(java.util.Map<java.lang.String,java.lang.Object> nonfunc, LocalAbstractConnectionHandler conhandler)
 - 
Method SummaryAll Methods Instance Methods Concrete Methods Modifier and Type Method Description voidflush()Flush the data.voidready(int available)Called by local input connection handler to signal that user has read some data.IFuture<java.lang.Void>send(byte[] data)Called from connection.IFuture<java.lang.Integer>waitForReady()Wait until the connection is ready for the next write.- 
Methods inherited from class jadex.bridge.component.streams.LocalAbstractConnectionHandlerclose, doClose, getConnection, getConnectionHandler, getConnectionId, getNonFunctionalProperties, initReceived, notifyInited, sendInit, setConnection, setConnectionHandler
 - 
Methods inherited from class java.lang.Objectclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 - 
Methods inherited from interface jadex.bridge.component.streams.IAbstractConnectionHandlerdoClose, getNonFunctionalProperties, notifyInited, sendInit, setConnection
 
- 
 
- 
- 
- 
Field Detail- 
maxstoredprotected int maxstored The maximum bytes of data that can be stored in connection (without being consumed).
 - 
readyfutureprotected Future<java.lang.Integer> readyfuture The ready future.
 
- 
 - 
Constructor Detail- 
LocalOutputConnectionHandlerpublic LocalOutputConnectionHandler(java.util.Map<java.lang.String,java.lang.Object> nonfunc) 
 - 
LocalOutputConnectionHandlerpublic LocalOutputConnectionHandler(java.util.Map<java.lang.String,java.lang.Object> nonfunc, LocalAbstractConnectionHandler conhandler)
 
- 
 - 
Method Detail- 
sendpublic IFuture<java.lang.Void> send(byte[] data) Called from connection.- Specified by:
- sendin interface- IOutputConnectionHandler
 
 - 
flushpublic void flush() Flush the data.- Specified by:
- flushin interface- IOutputConnectionHandler
 
 - 
waitForReadypublic IFuture<java.lang.Integer> waitForReady() Wait until the connection is ready for the next write.- Specified by:
- waitForReadyin interface- IOutputConnectionHandler
- Returns:
- Calls future when next data can be written.
 
 - 
readypublic void ready(int available) Called by local input connection handler to signal that user has read some data.
 
- 
 
-