Skip to content

Commit

Permalink
pass CancellationToken
Browse files Browse the repository at this point in the history
  • Loading branch information
zivillian committed Aug 22, 2023
1 parent cb4f016 commit 0146c93
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion RfpProxy.ChangeLed/Program.cs
Original file line number Diff line number Diff line change
Expand Up @@ -51,7 +51,7 @@ static async Task Main(string[] args)
cts.Cancel();
socket.Close();
};
await socket.ConnectAsync(new UnixDomainSocketEndPoint(socketname));
await socket.ConnectAsync(new UnixDomainSocketEndPoint(socketname), cts.Token);
cts.Token.ThrowIfCancellationRequested();
await SubscribeAsync(socket, cts.Token).ConfigureAwait(false);
await RunAsync(socket, cts.Token).ConfigureAwait(false);
Expand Down
2 changes: 1 addition & 1 deletion RfpProxy/TcpProxy.cs
Original file line number Diff line number Diff line change
Expand Up @@ -93,7 +93,7 @@ private async Task HandleClientAsync(TcpClient client, CancellationToken cancell
using (client)
using (var server = ConnectToServer(client))
{
await server.ConnectAsync(_server, _port).ConfigureAwait(false);
await server.ConnectAsync(_server, _port, cts.Token).ConfigureAwait(false);
var clientData = OnClientConnected(client, server);
try
{
Expand Down

0 comments on commit 0146c93

Please sign in to comment.