Lines Matching refs:stream_
58 stream_.reset(new QuicSpdyServerStream(3, &session_));
117 scoped_ptr<QuicReliableServerStream> stream_;
131 EXPECT_EQ(headers_string_.size(), stream_->ProcessData(
133 EXPECT_EQ(body_.size(), stream_->ProcessData(body_.c_str(), body_.size()));
134 EXPECT_EQ(11u, stream_->headers().content_length());
135 EXPECT_EQ("https://www.google.com/", stream_->headers().request_uri());
136 EXPECT_EQ("POST", stream_->headers().request_method());
137 EXPECT_EQ(body_, stream_->body());
146 EXPECT_EQ(message.size(), stream_->ProcessData(
148 EXPECT_EQ(11u, stream_->headers().content_length());
150 stream_->headers().request_uri());
151 EXPECT_EQ("POST", stream_->headers().request_method());
152 EXPECT_EQ(body_, stream_->body());
162 EXPECT_EQ(headers_string_.size(), stream_->ProcessData(
166 stream_->ProcessData(large_body.c_str(), large_body.size());
167 stream_->TerminateFromPeer(true);
168 EXPECT_EQ(11u, stream_->headers().content_length());
169 EXPECT_EQ("https://www.google.com/", stream_->headers().request_uri());
170 EXPECT_EQ("POST", stream_->headers().request_method());
175 QuicReliableServerStreamPeer::GetMutableHeaders(stream_.get());
193 stream_->SendResponse();
194 EXPECT_TRUE(stream_->read_side_closed());
195 EXPECT_TRUE(stream_->write_side_closed());
211 stream_->SendErrorResponse();
212 EXPECT_TRUE(stream_->read_side_closed());
213 EXPECT_TRUE(stream_->write_side_closed());
