RegisterForCancellation()

unsafe void System.IO.Pipes.PipeStream.PipeValueTaskSource.RegisterForCancellation ( CancellationToken cancellationToken )

inlinepackageinherited

Definition at line 82 of file PipeStream.cs.

        {
            if (!cancellationToken.CanBeCanceled)
            {
                return;
            }
            try
            {
                _cancellationRegistration = cancellationToken.UnsafeRegister(delegate(object s, CancellationToken token)
                {
                    PipeValueTaskSource pipeValueTaskSource = (PipeValueTaskSource)s;
                    if (!pipeValueTaskSource._pipeStream.SafePipeHandle.IsInvalid)
                    {
                        try
                        {
                            global::Interop.Kernel32.CancelIoEx(pipeValueTaskSource._pipeStream.SafePipeHandle, pipeValueTaskSource._overlapped);
                        }
                        catch (ObjectDisposedException)
                        {
                        }
                    }
                }, this);
            }
            catch (OutOfMemoryException)
            {
            }
        }

References System.IO.Pipes.PipeStream.PipeValueTaskSource.PipeValueTaskSource(), System.IO.Pipes.PipeStream.PipeValueTaskSource._cancellationRegistration, System.IO.Pipes.PipeStream.PipeValueTaskSource._overlapped, System.IO.Pipes.PipeStream.PipeValueTaskSource._pipeStream, System.cancellationToken, Microsoft.Win32.SafeHandles.SafeHandleZeroOrMinusOneIsInvalid.IsInvalid, System.s, and System.IO.Pipes.PipeStream.SafePipeHandle.

Referenced by System.IO.Pipes.PipeStream.ReadAsyncCore(), System.IO.Pipes.NamedPipeServerStream.WaitForConnectionCoreAsync(), and System.IO.Pipes.PipeStream.WriteAsyncCore().