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)
324
_stream
.Abort(QuicAbortDirection.Write, (long)Http3ErrorCode.RequestCancelled);
345
_stream
.Abort(QuicAbortDirection.Write, (long)Http3ErrorCode.InternalError);
350
_stream
.Abort(QuicAbortDirection.Write, (long)Http3ErrorCode.InternalError);
473
_stream
.CompleteWrites();
510
await
_stream
.WriteAsync(_sendBuffer.ActiveMemory, cancellationToken).ConfigureAwait(false);
511
await
_stream
.WriteAsync(buffer, cancellationToken).ConfigureAwait(false);
520
await
_stream
.WriteAsync(buffer, cancellationToken).ConfigureAwait(false);
529
await
_stream
.WriteAsync(_sendBuffer.ActiveMemory, cancellationToken).ConfigureAwait(false);
530
await
_stream
.WriteAsync(buffer, cancellationToken).ConfigureAwait(false);
540
return
_stream
.WriteAsync(toSend, endStream, cancellationToken);
850
bytesRead = await
_stream
.ReadAsync(_recvBuffer.AvailableMemory, cancellationToken).ConfigureAwait(false);
907
_stream
.Abort(QuicAbortDirection.Read, (long)Http3ErrorCode.ExcessiveLoad);
919
int bytesRead = await
_stream
.ReadAsync(_recvBuffer.AvailableMemory, cancellationToken).ConfigureAwait(false);
1118
int bytesRead = await
_stream
.ReadAsync(_recvBuffer.AvailableMemory, cancellationToken).ConfigureAwait(false);
1183
int bytesRead =
_stream
.Read(buffer.Slice(0, copyLen));
1255
int bytesRead = await
_stream
.ReadAsync(buffer.Slice(0, copyLen), cancellationToken).ConfigureAwait(false);
1321
_stream
.Abort(QuicAbortDirection.Read, (long)Http3ErrorCode.RequestCancelled);
1326
_stream
.Abort(QuicAbortDirection.Read, (long)Http3ErrorCode.InternalError);
1384
_stream
.Abort(QuicAbortDirection.Write, (long)Http3ErrorCode.RequestCancelled);
1389
_stream
.Abort(QuicAbortDirection.Read, (long)Http3ErrorCode.RequestCancelled);
1432
stream._connection.RemoveStream(stream.
_stream
);