NamedPipeConnectionListener.cs

    public class NamedPipeConnectionListener : IConnectionListener
    {
        private readonly NamedPipeEndPoint _endpoint;
        private readonly CancellationTokenSource _listeningSource = new CancellationTokenSource();

        public NamedPipeConnectionListener(NamedPipeEndPoint endpoint)
        {
            _endpoint = endpoint;
            ListeningToken = _listeningSource.Token;
        }

        public EndPoint EndPoint => _endpoint;

        public CancellationToken ListeningToken { get; }

        public async ValueTask<ConnectionContext> AcceptAsync(CancellationToken cancellationToken = default)
        {
            if (ListeningToken.IsCancellationRequested)
            {
                // We're done listening
                return null;
            }

            var stream = new NamedPipeServerStream(_endpoint.PipeName, PipeDirection.InOut, NamedPipeServerStream.MaxAllowedServerInstances, PipeTransmissionMode.Byte, _endpoint.PipeOptions);

            CancellationTokenSource source = null;
            CancellationToken effectiveToken = default;
            if (cancellationToken.CanBeCanceled)
            {
                source = CancellationTokenSource.CreateLinkedTokenSource(effectiveToken, ListeningToken);
                effectiveToken = source.Token;
            }
            else
            {
                effectiveToken = ListeningToken;
            }

            try
            {
                using (source)
                {
                    await stream.WaitForConnectionAsync(effectiveToken);
                }
            }
            catch (OperationCanceledException) when (ListeningToken.IsCancellationRequested)
            {
                // Cancelled the current token
                return null;
            }
            catch (ObjectDisposedException)
            {
                // Listener disposed
                return null;
            }

            return new NamedPipeConnectionContext(stream);
        }

        public ValueTask DisposeAsync()
        {
            _listeningSource.Dispose();
            return default;
        }

        public ValueTask UnbindAsync(CancellationToken cancellationToken = default)
        {
            _listeningSource.Cancel();
            return default;
        }
    }