Lines Matching defs:sink
193 testing::StreamSink sink;
199 sink.Monitor(client.get());
206 sink.Monitor(server.get());
212 EXPECT_FALSE(sink.Check(server.get(), testing::SSE_READ));
223 EXPECT_FALSE(sink.Check(client.get(), testing::SSE_OPEN));
224 EXPECT_FALSE(sink.Check(client.get(), testing::SSE_CLOSE));
227 EXPECT_TRUE_WAIT((sink.Check(server.get(), testing::SSE_READ)), kTimeout);
240 EXPECT_TRUE(sink.Check(client.get(), testing::SSE_OPEN));
241 EXPECT_FALSE(sink.Check(client.get(), testing::SSE_CLOSE));
248 testing::StreamSink sink;
254 sink.Monitor(client.get());
259 sink.Monitor(server.get());
272 EXPECT_FALSE(sink.Check(client.get(), testing::SSE_OPEN));
273 EXPECT_FALSE(sink.Check(client.get(), testing::SSE_CLOSE));
276 EXPECT_TRUE_WAIT((sink.Check(server.get(), testing::SSE_READ)), kTimeout);
289 EXPECT_TRUE(sink.Check(client.get(), testing::SSE_OPEN));
290 EXPECT_FALSE(sink.Check(client.get(), testing::SSE_CLOSE));
296 testing::StreamSink sink;
302 sink.Monitor(client.get());
307 sink.Monitor(server.get());
318 EXPECT_FALSE(sink.Check(client.get(), testing::SSE_OPEN));
319 EXPECT_TRUE(sink.Check(client.get(), testing::SSE_ERROR));
323 EXPECT_FALSE(sink.Check(server.get(), testing::SSE_READ));
329 testing::StreamSink sink;
335 sink.Monitor(client.get());
340 sink.Monitor(server.get());
360 EXPECT_FALSE(sink.Check(client.get(), testing::SSE_OPEN));
361 EXPECT_TRUE(sink.Check(client.get(), testing::SSE_ERROR));
364 EXPECT_FALSE(sink.Check(server.get(), testing::SSE_READ));
389 testing::StreamSink sink;
392 sink.Monitor(server.get());
406 EXPECT_TRUE_WAIT((sink.Check(server.get(), testing::SSE_READ)), kTimeout);
431 testing::StreamSink sink;
436 sink.Monitor(client.get());
441 sink.Monitor(server.get());
449 EXPECT_TRUE_WAIT(sink.Check(server.get(), testing::SSE_READ), kTimeout);
454 EXPECT_TRUE(sink.Check(client.get(), testing::SSE_ERROR));
459 testing::StreamSink sink;
465 sink.Monitor(client.get());
470 sink.Monitor(server.get());
478 EXPECT_TRUE_WAIT(sink.Check(server.get(), testing::SSE_READ), kTimeout);
484 sink.Monitor(accepted.get());
489 EXPECT_TRUE(sink.Check(accepted.get(), testing::SSE_CLOSE) ||
490 sink.Check(accepted.get(), testing::SSE_ERROR));
493 EXPECT_FALSE(sink.Check(client.get(), testing::SSE_CLOSE));
497 testing::StreamSink sink;
503 sink.Monitor(client.get());
508 sink.Monitor(server.get());
516 EXPECT_TRUE_WAIT((sink.Check(server.get(), testing::SSE_READ)), kTimeout);
519 sink.Monitor(accepted.get());
523 EXPECT_TRUE(sink.Check(client.get(), testing::SSE_OPEN));
533 EXPECT_TRUE_WAIT(sink.Check(client.get(), testing::SSE_READ), kTimeout);
534 EXPECT_FALSE(sink.Check(client.get(), testing::SSE_CLOSE));
544 EXPECT_TRUE(sink.Check(client.get(), testing::SSE_CLOSE));
548 EXPECT_FALSE(sink.Check(accepted.get(), testing::SSE_CLOSE));
553 EXPECT_FALSE(sink.Check(client.get(), testing::SSE_CLOSE));
557 EXPECT_FALSE(sink.Check(client.get(), testing::SSE_CLOSE));
570 testing::StreamSink sink;
577 sink.Monitor(client.get());
583 sink.Monitor(server.get());
591 EXPECT_TRUE_WAIT((sink.Check(server.get(), testing::SSE_READ)), kTimeout);
594 sink.Monitor(accepted.get());
598 EXPECT_TRUE(sink.Check(client.get(), testing::SSE_OPEN));
607 EXPECT_FALSE(sink.Check(client.get(), testing::SSE_CLOSE));
612 EXPECT_TRUE(sink.Check(client.get(), testing::SSE_CLOSE));
625 testing::StreamSink sink;
633 sink.Monitor(client.get());
634 sink.Monitor(server.get());
639 EXPECT_TRUE_WAIT((sink.Check(server.get(), testing::SSE_READ)), kTimeout);
643 sink.Monitor(accepted.get());
649 EXPECT_TRUE(sink.Check(client.get(), testing::SSE_OPEN));
650 EXPECT_FALSE(sink.Check(client.get(), testing::SSE_CLOSE));
655 EXPECT_FALSE(sink.Check(accepted.get(), testing::SSE_READ));
659 EXPECT_FALSE(sink.Check(accepted.get(), testing::SSE_READ));
667 EXPECT_FALSE(sink.Check(accepted.get(), testing::SSE_READ));
670 EXPECT_TRUE_WAIT((sink.Check(accepted.get(), testing::SSE_READ)), kTimeout);
675 testing::StreamSink sink;
691 sink.Monitor(client.get());
696 sink.Monitor(server.get());
704 EXPECT_TRUE_WAIT((sink.Check(server.get(), testing::SSE_READ)), kTimeout);
707 sink.Monitor(accepted.get());
711 EXPECT_TRUE(sink.Check(client.get(), testing::SSE_OPEN));
746 EXPECT_TRUE_WAIT(sink.Check(client.get(), testing::SSE_READ), kTimeout);
775 EXPECT_TRUE_WAIT(sink.Check(accepted.get(), testing::SSE_WRITE),
790 EXPECT_TRUE(sink.Check(client.get(), testing::SSE_CLOSE));
795 testing::StreamSink sink;
801 sink.Monitor(client.get());
806 sink.Monitor(server.get());
814 EXPECT_TRUE_WAIT((sink.Check(server.get(), testing::SSE_READ)), kTimeout);
817 sink.Monitor(accepted.get());
821 EXPECT_TRUE(sink.Check(client.get(), testing::SSE_OPEN));
826 EXPECT_TRUE_WAIT(sink.Check(accepted.get(), testing::SSE_WRITE), kTimeout);
835 EXPECT_TRUE_WAIT(sink.Check(client.get(), testing::SSE_READ), kTimeout);
843 EXPECT_TRUE_WAIT(sink.Check(accepted.get(), testing::SSE_WRITE), kTimeout);
851 if (sink.Check(accepted.get(), testing::SSE_WRITE)) {
