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)
22
public override void Complete(Exception? exception = null) =>
_pipe
.CompleteWriter(exception);
24
public override void CancelPendingFlush() =>
_pipe
.CancelPendingFlush();
29
public override void OnReaderCompleted(Action<Exception?, object?> callback, object? state) =>
_pipe
.OnReaderCompleted(callback, state);
32
public override ValueTask<FlushResult> FlushAsync(CancellationToken cancellationToken = default) =>
_pipe
.FlushAsync(cancellationToken);
34
public override void Advance(int bytes) =>
_pipe
.Advance(bytes);
36
public override Memory<byte> GetMemory(int sizeHint = 0) =>
_pipe
.GetMemory(sizeHint);
38
public override Span<byte> GetSpan(int sizeHint = 0) =>
_pipe
.GetSpan(sizeHint);
40
public ValueTaskSourceStatus GetStatus(short token) =>
_pipe
.GetFlushAsyncStatus();
42
public FlushResult GetResult(short token) =>
_pipe
.GetFlushAsyncResult();
44
public void OnCompleted(Action<object?> continuation, object? state, short token, ValueTaskSourceOnCompletedFlags flags) =>
_pipe
.OnFlushAsyncCompleted(continuation, state, flags);
46
public override long UnflushedBytes =>
_pipe
.GetUnflushedBytes();
50
return
_pipe
.WriteAsync(source, cancellationToken);