1 write to _pipe
System.IO.Pipelines (1)
System\IO\Pipelines\Pipe.DefaultPipeReader.cs (1)
19
_pipe
= pipe;
11 references to _pipe
System.IO.Pipelines (11)
System\IO\Pipelines\Pipe.DefaultPipeReader.cs (11)
22
public override bool TryRead(out ReadResult result) =>
_pipe
.TryRead(out result);
24
public override ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default) =>
_pipe
.ReadAsync(cancellationToken);
26
protected override ValueTask<ReadResult> ReadAtLeastAsyncCore(int minimumBytes, CancellationToken cancellationToken) =>
_pipe
.ReadAtLeastAsync(minimumBytes, cancellationToken);
28
public override void AdvanceTo(SequencePosition consumed) =>
_pipe
.AdvanceReader(consumed);
30
public override void AdvanceTo(SequencePosition consumed, SequencePosition examined) =>
_pipe
.AdvanceReader(consumed, examined);
32
public override void CancelPendingRead() =>
_pipe
.CancelPendingRead();
34
public override void Complete(Exception? exception = null) =>
_pipe
.CompleteReader(exception);
37
public override void OnWriterCompleted(Action<Exception?, object?> callback, object? state) =>
_pipe
.OnWriterCompleted(callback, state);
40
public ValueTaskSourceStatus GetStatus(short token) =>
_pipe
.GetReadAsyncStatus();
42
public ReadResult GetResult(short token) =>
_pipe
.GetReadAsyncResult();
44
public void OnCompleted(Action<object?> continuation, object? state, short token, ValueTaskSourceOnCompletedFlags flags) =>
_pipe
.OnReadAsyncCompleted(continuation, state, flags);