Skip to content

Commit 6f9e12c

Browse files
committed
Remove use of NO_BEGINCONNECT
1 parent 74ab931 commit 6f9e12c

1 file changed

Lines changed: 1 addition & 33 deletions

File tree

‎NBitcoin/Protocol/Connectors/SocketExtensions.cs‎

Lines changed: 1 addition & 33 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@ public static Task ConnectAsync(this Socket socket, EndPoint remoteEP, Cancellat
1616
{
1717
return socket.ConnectAsync(remoteEP, cancellationToken).AsTask();
1818
}
19-
#elif !NO_BEGINCONNECT
19+
#else
2020
public static Task ConnectAsync(this Socket socket, EndPoint remoteEP, CancellationToken cancellationToken)
2121
{
2222
var tcs = new TaskCompletionSource<bool>(socket);
@@ -32,38 +32,6 @@ public static Task ConnectAsync(this Socket socket, EndPoint remoteEP, Cancellat
3232
}, tcs);
3333
return tcs.Task.WithCancellation(cancellationToken);
3434
}
35-
#else
36-
public static async Task ConnectAsync(this Socket socket, EndPoint remoteEP, CancellationToken cancellationToken)
37-
{
38-
var completion = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);
39-
var args = new SocketAsyncEventArgs();
40-
using (cancellationToken.Register(() =>
41-
{
42-
completion.TrySetCanceled();
43-
}, false))
44-
{
45-
args.RemoteEndPoint = remoteEP;
46-
args.Completed += (s, a) =>
47-
{
48-
completion.TrySetResult(true);
49-
};
50-
if (!socket.ConnectAsync(args))
51-
{
52-
completion.TrySetResult(true);
53-
}
54-
try
55-
{
56-
await completion.Task.ConfigureAwait(false);
57-
}
58-
catch
59-
{
60-
cancellationToken.ThrowIfCancellationRequested();
61-
throw;
62-
}
63-
}
64-
if (args.SocketError != SocketError.Success)
65-
throw new SocketException((int)args.SocketError);
66-
}
6735
#endif
6836
}
6937
}

0 commit comments

Comments
 (0)