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)
328
_stream
.Abort(QuicAbortDirection.Write, (long)Http3ErrorCode.RequestCancelled);
349
_stream
.Abort(QuicAbortDirection.Write, (long)Http3ErrorCode.InternalError);
354
_stream
.Abort(QuicAbortDirection.Write, (long)Http3ErrorCode.InternalError);
477
_stream
.CompleteWrites();
518
await
_stream
.WriteAsync(_sendBuffer.ActiveMemory, cancellationToken).ConfigureAwait(false);
519
await
_stream
.WriteAsync(buffer, cancellationToken).ConfigureAwait(false);
528
await
_stream
.WriteAsync(buffer, cancellationToken).ConfigureAwait(false);
537
await
_stream
.WriteAsync(_sendBuffer.ActiveMemory, cancellationToken).ConfigureAwait(false);
538
await
_stream
.WriteAsync(buffer, cancellationToken).ConfigureAwait(false);
548
return
_stream
.WriteAsync(toSend, endStream, cancellationToken);
858
bytesRead = await
_stream
.ReadAsync(_recvBuffer.AvailableMemory, cancellationToken).ConfigureAwait(false);
915
_stream
.Abort(QuicAbortDirection.Read, (long)Http3ErrorCode.ExcessiveLoad);
927
int bytesRead = await
_stream
.ReadAsync(_recvBuffer.AvailableMemory, cancellationToken).ConfigureAwait(false);
1126
int bytesRead = await
_stream
.ReadAsync(_recvBuffer.AvailableMemory, cancellationToken).ConfigureAwait(false);
1191
int bytesRead =
_stream
.Read(buffer.Slice(0, copyLen));
1263
int bytesRead = await
_stream
.ReadAsync(buffer.Slice(0, copyLen), cancellationToken).ConfigureAwait(false);
1329
_stream
.Abort(QuicAbortDirection.Read, (long)Http3ErrorCode.RequestCancelled);
1334
_stream
.Abort(QuicAbortDirection.Read, (long)Http3ErrorCode.InternalError);
1392
_stream
.Abort(QuicAbortDirection.Write, (long)Http3ErrorCode.RequestCancelled);
1397
_stream
.Abort(QuicAbortDirection.Read, (long)Http3ErrorCode.RequestCancelled);
1440
stream._connection.RemoveStream(stream.
_stream
);