| // Copyright (c) 2018 The Chromium Authors. All rights reserved. | |
| // Use of this source code is governed by a BSD-style license that can be | |
| // found in the LICENSE file. | |
| #include "net/third_party/quiche/src/quic/tools/quic_simple_client_stream.h" | |
| namespace quic { | |
| void QuicSimpleClientStream::OnBodyAvailable() { | |
| if (!drop_response_body_) { | |
| QuicSpdyClientStream::OnBodyAvailable(); | |
| return; | |
| } | |
| while (HasBytesToRead()) { | |
| struct iovec iov; | |
| if (GetReadableRegions(&iov, 1) == 0) { | |
| break; | |
| } | |
| MarkConsumed(iov.iov_len); | |
| } | |
| if (sequencer()->IsClosed()) { | |
| OnFinRead(); | |
| } else { | |
| sequencer()->SetUnblocked(); | |
| } | |
| } | |
| void QuicSimpleClientStream::OnStopSending(uint16_t code) { | |
| last_stop_sending_code_ = code; | |
| } | |
| } // namespace quic |