◆ DrainAsync()

override async ValueTask< bool > System.Net.Http.HttpConnection.ChunkedEncodingReadStream.DrainAsync ( int maxDrainBytes )

inlinevirtual

Reimplemented from System.Net.Http.HttpConnection.HttpContentReadStream.

Definition at line 321 of file HttpConnection.cs.

        {
            CancellationTokenSource cts = null;
            CancellationTokenRegistration ctr = default(CancellationTokenRegistration);
            try
            {
                int drainedBytes = 0;
                while (true)
                {
                    drainedBytes += _connection.RemainingBuffer.Length;
                    while (ReadChunkFromConnectionBuffer(int.MaxValue, ctr).Length != 0)
                    {
                    }
                    if (_connection == null)
                    {
                        return true;
                    }
                    if (drainedBytes >= maxDrainBytes)
                    {
                        return false;
                    }
                    if (cts == null)
                    {
                        TimeSpan maxResponseDrainTime = _connection._pool.Settings._maxResponseDrainTime;
                        if (maxResponseDrainTime == TimeSpan.Zero)
                        {
                            break;
                        }
                        if (maxResponseDrainTime != Timeout.InfiniteTimeSpan)
                        {
                            cts = new CancellationTokenSource((int)maxResponseDrainTime.TotalMilliseconds);
                            ctr = cts.Token.Register(delegate(object s)
                            {
                                ((HttpConnection)s).Dispose();
                            }, _connection);
                        }
                    }
                    await _connection.FillAsync(async: true).ConfigureAwait(continueOnCapturedContext: false);
                }
                return false;
            }
            finally
            {
                ctr.Dispose();
                cts?.Dispose();
            }
        }