Test
 
Test 2
Collecting message...
Reading pipe async
[NORMAL]Discovering patches...
[NORMAL]No patches in this directory...
[NORMAL]Connecting...
[GOOD]Connected
Exception thrown: 'System.OperationCanceledException' in System.Core.dll
An exception of type 'System.OperationCanceledException' occurred in System.Core.dll but was not handled in user code
The operation was canceled.

Exception thrown: 'System.OperationCanceledException' in mscorlib.dll
Exception thrown: 'System.OperationCanceledException' in mscorlib.dll
Exception thrown: 'System.OperationCanceledException' in mscorlib.dll
Exception thrown: 'System.OperationCanceledException' in mscorlib.dll
Cancelled

Test
 
Test 2
Collecting message...
Reading pipe async
[NORMAL]Discovering patches...
[NORMAL]No patches in this directory...
[NORMAL]Connecting...
[GOOD]Connected
Exception thrown: 'System.OperationCanceledException' in System.Core.dll
An exception of type 'System.OperationCanceledException' occurred in System.Core.dll but was not handled in user code
The operation was canceled.

Exception thrown: 'System.OperationCanceledException' in mscorlib.dll
Exception thrown: 'System.OperationCanceledException' in mscorlib.dll
Exception thrown: 'System.OperationCanceledException' in mscorlib.dll
Exception thrown: 'System.OperationCanceledException' in mscorlib.dll
Cancelled

c#
 try
 {
     var msg = await _protocol.Receive(TimeSpan.FromSeconds(2));
     Console.WriteLine(msg.Identifier);
 }
 catch (OperationCanceledException)
 {
     Console.WriteLine("Cancelled");
 }

c#
 try
 {
     var msg = await _protocol.Receive(TimeSpan.FromSeconds(2));
     Console.WriteLine(msg.Identifier);
 }
 catch (OperationCanceledException)
 {
     Console.WriteLine("Cancelled");
 }

c#
private static Task<int> ReadPipeAsync(PipeStream pipe, byte[] buffer, int offset, int count, CancellationToken cancellationToken)
{
    if (cancellationToken.IsCancellationRequested) return Task.FromCanceled<int>(cancellationToken);
    var registration = cancellationToken.Register(() => CancelPipeIo(pipe));
    var result = pipe.BeginRead(buffer, offset, count, null, null);
    Console.WriteLine("Reading pipe async");
    return Task.Run(() =>
    {
        try { return pipe.EndRead(result); }
        finally { registration.Dispose(); }
    }, cancellationToken);
}

c#
private static Task<int> ReadPipeAsync(PipeStream pipe, byte[] buffer, int offset, int count, CancellationToken cancellationToken)
{
    if (cancellationToken.IsCancellationRequested) return Task.FromCanceled<int>(cancellationToken);
    var registration = cancellationToken.Register(() => CancelPipeIo(pipe));
    var result = pipe.BeginRead(buffer, offset, count, null, null);
    Console.WriteLine("Reading pipe async");
    return Task.Run(() =>
    {
        try { return pipe.EndRead(result); }
        finally { registration.Dispose(); }
    }, cancellationToken);
}