New channel interaction module ctor
This commit is contained in:
@@ -15,17 +15,20 @@ namespace mROA.Implementation
|
|||||||
private readonly ChannelWriter<NetworkMessageHeader> _untrustedWriter;
|
private readonly ChannelWriter<NetworkMessageHeader> _untrustedWriter;
|
||||||
private readonly Channel<NetworkMessageHeader> _outputTrustedChannel;
|
private readonly Channel<NetworkMessageHeader> _outputTrustedChannel;
|
||||||
private readonly Channel<NetworkMessageHeader> _outputUntrustedChannel;
|
private readonly Channel<NetworkMessageHeader> _outputUntrustedChannel;
|
||||||
private IContextualSerializationToolKit _serialization;
|
private readonly IContextualSerializationToolKit _serialization;
|
||||||
private bool _isConnected = true;
|
private bool _isConnected = true;
|
||||||
private bool _isActive = true;
|
private bool _isActive = true;
|
||||||
private TaskCompletionSource<Stream> _reconnection;
|
private TaskCompletionSource<Stream> _reconnection;
|
||||||
|
|
||||||
public ChannelInteractionModule(IContextualSerializationToolKit serialization,
|
public ChannelInteractionModule(IContextualSerializationToolKit serialization,
|
||||||
IIdentityGenerator identityGenerator)
|
IIdentityGenerator identityGenerator) : this(serialization)
|
||||||
|
{
|
||||||
|
ConnectionId = identityGenerator.GetNextIdentity();
|
||||||
|
}
|
||||||
|
|
||||||
|
public ChannelInteractionModule(IContextualSerializationToolKit serialization)
|
||||||
{
|
{
|
||||||
_serialization = serialization;
|
_serialization = serialization;
|
||||||
ConnectionId = identityGenerator.GetNextIdentity();
|
|
||||||
|
|
||||||
ReceiveChanel = Channel.CreateUnbounded<NetworkMessageHeader>(new UnboundedChannelOptions
|
ReceiveChanel = Channel.CreateUnbounded<NetworkMessageHeader>(new UnboundedChannelOptions
|
||||||
{
|
{
|
||||||
SingleReader = false,
|
SingleReader = false,
|
||||||
@@ -46,7 +49,7 @@ namespace mROA.Implementation
|
|||||||
_untrustedWriter = _outputUntrustedChannel.Writer;
|
_untrustedWriter = _outputUntrustedChannel.Writer;
|
||||||
_reconnection = new TaskCompletionSource<Stream>();
|
_reconnection = new TaskCompletionSource<Stream>();
|
||||||
}
|
}
|
||||||
|
|
||||||
public int ConnectionId { get; set; }
|
public int ConnectionId { get; set; }
|
||||||
|
|
||||||
public IEndPointContext Context { get; set; }
|
public IEndPointContext Context { get; set; }
|
||||||
|
|||||||
Reference in New Issue
Block a user