1 write to _pipe
System.IO.Pipelines (1)
System\IO\Pipelines\Pipe.DefaultPipeWriter.cs (1)
19_pipe = pipe;
12 references to _pipe
System.IO.Pipelines (12)
System\IO\Pipelines\Pipe.DefaultPipeWriter.cs (12)
22public override void Complete(Exception? exception = null) => _pipe.CompleteWriter(exception); 24public override void CancelPendingFlush() => _pipe.CancelPendingFlush(); 29public override void OnReaderCompleted(Action<Exception?, object?> callback, object? state) => _pipe.OnReaderCompleted(callback, state); 32public override ValueTask<FlushResult> FlushAsync(CancellationToken cancellationToken = default) => _pipe.FlushAsync(cancellationToken); 34public override void Advance(int bytes) => _pipe.Advance(bytes); 36public override Memory<byte> GetMemory(int sizeHint = 0) => _pipe.GetMemory(sizeHint); 38public override Span<byte> GetSpan(int sizeHint = 0) => _pipe.GetSpan(sizeHint); 40public ValueTaskSourceStatus GetStatus(short token) => _pipe.GetFlushAsyncStatus(); 42public FlushResult GetResult(short token) => _pipe.GetFlushAsyncResult(); 44public void OnCompleted(Action<object?> continuation, object? state, short token, ValueTaskSourceOnCompletedFlags flags) => _pipe.OnFlushAsyncCompleted(continuation, state, flags); 46public override long UnflushedBytes => _pipe.GetUnflushedBytes(); 50return _pipe.WriteAsync(source, cancellationToken);