sochix/TLSharp
1
0
Fork 0
mirror of https://github.com/sochix/TLSharp.git synced 2025-12-06 08:02:00 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

Reverts refactoring in TcpTransport

Browse source
This commit is contained in:
Ruslan Iarmukhamedov 2019-10-25 11:38:17 +06:00
parent ef100652b2
commit 2a2937aedf
1 changed files with 10 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
TLSharp.Core/Network/TcpTransport.cs
View file

@ -12,7 +12,7 @@ namespace TLSharp.Core.Network
{ {
private readonly TcpClient _tcpClient; private readonly TcpClient _tcpClient;
private readonly NetworkStream _stream; private readonly NetworkStream _stream;
private int _sendCounter; private int sendCounter = 0;
public TcpTransport(string address, int port, TcpClientConnectionHandler handler = null) public TcpTransport(string address, int port, TcpClientConnectionHandler handler = null)
{ {
@ -38,10 +38,10 @@ namespace TLSharp.Core.Network
if (!_tcpClient.Connected) if (!_tcpClient.Connected)
throw new InvalidOperationException("Client not connected to server."); throw new InvalidOperationException("Client not connected to server.");
var tcpMessage = new TcpMessage(_sendCounter, packet); var tcpMessage = new TcpMessage(sendCounter, packet);
await _stream.WriteAsync(tcpMessage.Encode(), 0, tcpMessage.Encode().Length, token).ConfigureAwait(false); await _stream.WriteAsync(tcpMessage.Encode(), 0, tcpMessage.Encode().Length, token).ConfigureAwait(false);
_sendCounter++; sendCounter++;
} }
public async Task<TcpMessage> Receive(CancellationToken token) public async Task<TcpMessage> Receive(CancellationToken token)
@ -95,7 +95,13 @@ namespace TLSharp.Core.Network
return new TcpMessage(seq, body); return new TcpMessage(seq, body);
} }
public bool IsConnected => _tcpClient.Connected; public bool IsConnected
{
get
{
return this._tcpClient.Connected;
}
}
public void Dispose() public void Dispose()