Home | History | Annotate | Download | only in websockets

Lines Matching refs:stream_

77   scoped_ptr<WebSocketBasicStream> stream_;
114 // stream_ has a reference to socket_data_ (via MockTCPClientSocket) and so
116 stream_.reset();
150 stream_ = WebSocketBasicStream::CreateWebSocketBasicStreamForTesting(
274 int result = stream_->ReadFrames(&frames_, cb_.callback());
283 int result = stream_->ReadFrames(&frames_, cb_.callback());
296 int result = stream_->ReadFrames(&frames_, cb_.callback());
306 int result = stream_->ReadFrames(&frames_, cb_.callback());
319 int result = stream_->ReadFrames(&frames_, cb_.callback());
333 EXPECT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback()));
340 EXPECT_EQ(OK, stream_->ReadFrames(&frames_, cb_.callback()));
352 EXPECT_EQ(OK, stream_->ReadFrames(&frames_, cb_.callback()));
368 EXPECT_EQ(OK, stream_->ReadFrames(&frames_, cb_.callback()));
373 EXPECT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback()));
393 ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb[0].callback()));
400 ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb[1].callback()));
417 ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb[0].callback()));
423 ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb[1].callback()));
443 ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb[0].callback()));
452 ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb[i].callback()));
464 EXPECT_EQ(OK, stream_->ReadFrames(&frames_, cb_.callback()));
476 stream_->ReadFrames(&frames_, cb_.callback()));
482 ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback()));
494 stream_->ReadFrames(&frames_, cb_.callback()));
500 ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback()));
510 stream_->ReadFrames(&frames_, cb_.callback()));
516 ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback()));
531 EXPECT_EQ(OK, stream_->ReadFrames(&frames_, cb_.callback()));
535 stream_->ReadFrames(&frames_, cb_.callback()));
545 ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback()));
556 ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback()));
564 EXPECT_EQ(OK, stream_->ReadFrames(&frames_, cb_.callback()));
578 EXPECT_EQ(OK, stream_->ReadFrames(&frames_, cb_.callback()));
581 EXPECT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback()));
595 EXPECT_EQ(OK, stream_->ReadFrames(&frames_, cb_.callback()));
598 ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback()));
609 EXPECT_EQ(OK, stream_->ReadFrames(&frames_, cb_.callback()));
625 EXPECT_EQ(OK, stream_->ReadFrames(&frames_, cb_.callback()));
629 EXPECT_EQ(OK, stream_->ReadFrames(&frames_, cb_.callback()));
640 EXPECT_EQ(OK, stream_->ReadFrames(&frames_, cb_.callback()));
653 ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback()));
671 ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback()));
691 EXPECT_EQ(OK, stream_->ReadFrames(&frames_, cb_.callback()));
701 stream_->ReadFrames(&frames_, cb_.callback()));
707 ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback()));
719 stream_->ReadFrames(&frames_, cb_.callback()));
731 stream_->ReadFrames(&frames_, cb_.callback()));
748 stream_->ReadFrames(&frames_, cb_.callback()));
763 ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback()));
777 EXPECT_EQ(OK, stream_->ReadFrames(&frames_, cb_.callback()));
789 ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb_.callback()));
818 ASSERT_EQ(ERR_IO_PENDING, stream_
846 ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb[0].callback()));
852 ASSERT_EQ(ERR_IO_PENDING, stream_->ReadFrames(&frames_, cb[1].callback()));
863 EXPECT_EQ(OK, stream_->WriteFrames(&frames_, cb_.callback()));
871 ASSERT_EQ(ERR_IO_PENDING, stream_->WriteFrames(&frames_, cb_.callback()));
884 ASSERT_EQ(ERR_IO_PENDING, stream_->WriteFrames(&frames_, cb_.callback()));
902 EXPECT_EQ(OK, stream_->WriteFrames(&frames, cb_.callback()));
927 EXPECT_EQ(OK, stream_->WriteFrames(&frames_, cb_.callback()));
934 EXPECT_EQ("inflate-uuencode", stream_->GetExtensions());
941 EXPECT_EQ("cyberchat", stream_->GetSubProtocol());