class Any2AnyConnectionImpl<T> extends AbstractConnectionImpl implements Any2AnyConnection<T>
Any2AnyConnection
.
Each end is safe to be used by one thread at a time.AbstractConnectionImpl.NonSingleRequestOpenMsg
Modifier and Type | Field and Description |
---|---|
private Any2OneChannel<T> |
chanClientSynch |
private One2OneChannel<T> |
chanFromServer |
private Any2OneChannel<T> |
chanServerSynch |
private One2OneChannel<T> |
chanToServer |
CLIENT_STATE_CLOSED, CLIENT_STATE_MADE_REQ, CLIENT_STATE_OPEN, nonSingleRequestMsg, SERVER_STATE_CLOSED, SERVER_STATE_OPEN, SERVER_STATE_RECEIVED
Constructor and Description |
---|
Any2AnyConnectionImpl()
Initializes all the attributes to necessary values.
|
Modifier and Type | Method and Description |
---|---|
SharedAltingConnectionClient |
client()
Returns a
SharedAltingConnectionClient object for this
connection. |
SharedConnectionServer |
server()
Returns a
SharedConnectionServer object for this
connection. |
private One2OneChannel<T> chanToServer
private One2OneChannel<T> chanFromServer
private Any2OneChannel<T> chanClientSynch
private Any2OneChannel<T> chanServerSynch
public Any2AnyConnectionImpl()
ChannelServer
inteface.
Constructor for One2OneConnectionImpl.public SharedAltingConnectionClient client()
SharedAltingConnectionClient
object for this
connection. This method can be called multiple times to return a new
SharedAltingConnectionClient
object each time. Any object
created can only be used by one process at a time but the set of
objects constructed can be used concurrently.client
in interface Any2AnyConnection<T>
client
in interface ConnectionWithSharedAltingClient<T>
SharedAltingConnectionClient
object.public SharedConnectionServer server()
SharedConnectionServer
object for this
connection. This method can be called multiple times to return a new
SharedConnectionServer
object each time. Any object
created can only be used by one process at a time but the set of
objects constructed can be used concurrently.server
in interface Any2AnyConnection<T>
server
in interface ConnectionWithSharedAltingServer<T>
SharedConnectionServer
object.