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

! IsConnected is restored as it was before

Browse source 
+ TcpTransport has got a connect method which properly initializes the underlying tcpclient
This commit is contained in:
solarin 2020-04-08 22:54:40 +04:00
parent e8ba470357
commit 47cc3405cf
1 changed files with 18 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -10,19 +10,28 @@ namespace TLSharp.Core.Network
public class TcpTransport : IDisposable public class TcpTransport : IDisposable
{ {
private readonly TcpClient tcpClient; private TcpClient tcpClient;
private readonly NetworkStream stream; private NetworkStream stream;
private int sendCounter = 0; private int sendCounter = 0;
TcpClientConnectionHandler handler;
string address;
int port;
IPAddress ipAddress;
public TcpTransport(string address, int port, TcpClientConnectionHandler handler = null) public TcpTransport(string address, int port, TcpClientConnectionHandler handler = null)
{
this.handler = handler;
this.address = address;
this.port = port;
ipAddress = IPAddress.Parse(address);
tcpClient = new TcpClient(ipAddress.AddressFamily);
}
public async Task Connect()
{ {
if (handler == null) if (handler == null)
{ {
var ipAddress = IPAddress.Parse(address); await tcpClient.ConnectAsync(ipAddress, port);
var endpoint = new IPEndPoint(ipAddress, port);
tcpClient = new TcpClient(ipAddress.AddressFamily);
tcpClient.Connect(endpoint);
} }
else else
tcpClient = handler(address, port); tcpClient = handler(address, port);
@ -31,8 +40,9 @@ namespace TLSharp.Core.Network
{ {
stream = tcpClient.GetStream(); stream = tcpClient.GetStream();
} }
else
stream = null;
} }
public async Task Send(byte[] packet, CancellationToken token = default(CancellationToken)) public async Task Send(byte[] packet, CancellationToken token = default(CancellationToken))
{ {
if (!tcpClient.Connected) if (!tcpClient.Connected)