public class ServiceInputConnection extends Object implements IInputConnection
Constructor and Description |
---|
ServiceInputConnection()
Create a new service input connection.
|
Modifier and Type | Method and Description |
---|---|
ISubscriptionIntermediateFuture<byte[]> |
aread()
Asynchronous read.
|
int |
available()
Get the number of available bytes.
|
void |
close()
Close the stream.
|
int |
getConnectionId()
Get the connection id.
|
IComponentIdentifier |
getInitiator()
Get the initiator.
|
Map<String,Object> |
getNonFunctionalProperties()
Get the non-functional properties of the connection.
|
IOutputConnection |
getOutputConnection()
Get the corresponding output connection.
|
IComponentIdentifier |
getParticipant()
Get the participant.
|
int |
read()
Non-blocking read.
|
int |
read(byte[] buffer)
Non-blocking read.
|
ISubscriptionIntermediateFuture<Long> |
writeToOutputStream(OutputStream os,
IExternalAccess component)
Read all data from output stream to the connection.
|
public ServiceInputConnection()
public int read()
read
in interface IInputConnection
public int read(byte[] buffer)
read
in interface IInputConnection
buffer
- The buffer to read in.public ISubscriptionIntermediateFuture<byte[]> aread()
aread
in interface IInputConnection
public int available()
available
in interface IInputConnection
public int getConnectionId()
getConnectionId
in interface IConnection
public void close()
close
in interface IConnection
public IComponentIdentifier getInitiator()
getInitiator
in interface IConnection
public IComponentIdentifier getParticipant()
getParticipant
in interface IConnection
public Map<String,Object> getNonFunctionalProperties()
getNonFunctionalProperties
in interface IConnection
public IOutputConnection getOutputConnection()
public ISubscriptionIntermediateFuture<Long> writeToOutputStream(OutputStream os, IExternalAccess component)
writeToOutputStream
in interface IInputConnection
is
- The input stream.component
- The component.Copyright © 2013. All Rights Reserved.