1 write to _stream
System.Net.Http (1)
System\Net\Http\SocketsHttpHandler\Http3RequestStream.cs (1)
72
_stream
= stream;
30 references to _stream
System.Net.Http (30)
System\Net\Http\SocketsHttpHandler\Http3RequestStream.cs (30)
91
if (
_stream
.WritesClosed.IsCompleted)
93
_connection.LogExceptions(
_stream
.DisposeAsync().AsTask());
97
_stream
.Dispose();
107
_connection.RemoveStream(
_stream
);
117
if (
_stream
.WritesClosed.IsCompleted)
119
_connection.LogExceptions(
_stream
.DisposeAsync().AsTask());
123
await
_stream
.DisposeAsync().ConfigureAwait(false);
131
_connection.RemoveStream(
_stream
);
219
_stream
.WritesClosed is { IsCompletedSuccessfully: false } writesClosed)
334
_stream
.Abort(QuicAbortDirection.Write, (long)Http3ErrorCode.RequestCancelled);
355
_stream
.Abort(QuicAbortDirection.Write, (long)Http3ErrorCode.InternalError);
360
_stream
.Abort(QuicAbortDirection.Write, (long)Http3ErrorCode.InternalError);
483
_stream
.CompleteWrites();
524
await
_stream
.WriteAsync(_sendBuffer.ActiveMemory, cancellationToken).ConfigureAwait(false);
525
await
_stream
.WriteAsync(buffer, cancellationToken).ConfigureAwait(false);
534
await
_stream
.WriteAsync(buffer, cancellationToken).ConfigureAwait(false);
543
await
_stream
.WriteAsync(_sendBuffer.ActiveMemory, cancellationToken).ConfigureAwait(false);
544
await
_stream
.WriteAsync(buffer, cancellationToken).ConfigureAwait(false);
554
return
_stream
.WriteAsync(toSend, endStream, cancellationToken);
864
bytesRead = await
_stream
.ReadAsync(_recvBuffer.AvailableMemory, cancellationToken).ConfigureAwait(false);
921
_stream
.Abort(QuicAbortDirection.Read, (long)Http3ErrorCode.ExcessiveLoad);
933
int bytesRead = await
_stream
.ReadAsync(_recvBuffer.AvailableMemory, cancellationToken).ConfigureAwait(false);
1132
int bytesRead = await
_stream
.ReadAsync(_recvBuffer.AvailableMemory, cancellationToken).ConfigureAwait(false);
1197
int bytesRead =
_stream
.Read(buffer.Slice(0, copyLen));
1269
int bytesRead = await
_stream
.ReadAsync(buffer.Slice(0, copyLen), cancellationToken).ConfigureAwait(false);
1335
_stream
.Abort(QuicAbortDirection.Read, (long)Http3ErrorCode.RequestCancelled);
1340
_stream
.Abort(QuicAbortDirection.Read, (long)Http3ErrorCode.InternalError);
1398
_stream
.Abort(QuicAbortDirection.Write, (long)Http3ErrorCode.RequestCancelled);
1403
_stream
.Abort(QuicAbortDirection.Read, (long)Http3ErrorCode.RequestCancelled);
1446
stream._connection.RemoveStream(stream.
_stream
);