Lines Matching defs:stream
78 FramedStream stream = connection.newStream(headerEntries("b", "banana"), true, true);
79 assertEquals(headerEntries("a", "android"), stream.getResponseHeaders());
80 assertStreamData("robot", stream.getSource());
81 BufferedSink out = Okio.buffer(stream.getSink());
107 FramedStream stream = connection.newStream(headerEntries("a", "android"), false, false);
109 assertEquals(headerEntries("b", "banana"), stream.getResponseHeaders());
154 @Override public void onStream(FramedStream stream) throws IOException {
156 assertEquals(pushHeaders, stream.getRequestHeaders());
157 assertEquals(null, stream.getErrorCode());
158 stream.reply(headerEntries("b", "banana"), true);
185 @Override public void onStream(FramedStream stream) throws IOException {
186 stream.reply(headerEntries("b", "banana"), false);
270 @Override public void onStream(FramedStream stream) throws IOException {
401 FramedStream stream = connection.newStream(headerEntries("a", "android"), true, false);
402 BufferedSink out = Okio.buffer(stream.getSink());
444 FramedStream stream = connection.newStream(headerEntries("a", "android"), true, true);
445 BufferedSink out = Okio.buffer(stream.getSink());
452 assertEquals("stream was reset: CANCEL", expected.getMessage());
475 * output stream.
485 FramedStream stream = connection.newStream(headerEntries("a", "android"), false, true);
486 Source in = stream.getSource();
487 BufferedSink out = Okio.buffer(stream.getSink());
493 assertEquals("stream closed", expected.getMessage());
500 assertEquals("stream finished", expected.getMessage());
517 * the output stream.
529 FramedStream stream = connection.newStream(headerEntries("a", "android"), true, true);
530 Source source = stream.getSource();
531 BufferedSink out = Okio.buffer(stream.getSink());
537 assertEquals("stream closed", expected.getMessage());
573 FramedStream stream = connection.newStream(headerEntries("a", "android"), false, true);
574 Source source = stream.getSource();
599 FramedStream stream = connection.newStream(headerEntries("c", "cola"), true, true);
600 assertEquals(headerEntries("a", "android"), stream.getResponseHeaders());
603 stream.getSource().read(new Buffer(), 1);
606 assertEquals("stream was reset: STREAM_IN_USE", expected.getMessage());
632 @Override public void onStream(FramedStream stream) throws IOException {
634 assertEquals(headerEntries("a", "android"), stream.getRequestHeaders());
635 assertEquals(null, stream.getErrorCode());
636 stream.reply(headerEntries("c", "cola"), true);
661 peer.sendFrame().ping(false, 2, 0); // Ping just to make sure the stream was fastforwarded.
667 FramedStream stream = connection.newStream(headerEntries("b", "banana"), true, true);
668 assertEquals(headerEntries("a", "android"), stream.getResponseHeaders());
669 assertStreamData("robot", stream.getSource());
686 peer.sendFrame().ping(false, 2, 0); // Ping just to make sure the stream was fastforwarded.
692 FramedStream stream = connection.newStream(headerEntries("a", "android"), true, true);
693 assertEquals(headerEntries("b", "banana"), stream.getResponseHeaders());
714 FramedStream stream = connection.newStream(headerEntries("a", "android"), true, true);
716 stream.getResponseHeaders();
719 assertEquals("stream was reset: REFUSED_STREAM", expected.getMessage());
741 peer.acceptFrame(); // DATA STREAM 1
757 assertEquals("stream was reset: REFUSED_STREAM", expected.getMessage());
842 FramedStream stream = connection.newStream(headerEntries("a", "android"), true, true);
852 BufferedSink sink = Okio.buffer(stream.getSink());
858 assertEquals("stream was reset: CANCEL", expected.getMessage());
861 stream.getSource().read(new Buffer(), 1);
864 assertEquals("stream was reset: CANCEL", expected.getMessage());
899 FramedStream stream = connection.newStream(headerEntries("b", "banana"), true, true);
900 stream.readTimeout().timeout(500, TimeUnit.MILLISECONDS);
903 stream.getResponseHeaders();
926 FramedStream stream = connection.newStream(headerEntries("b", "banana"), true, true);
927 stream.readTimeout().timeout(500, TimeUnit.MILLISECONDS);
928 Source source = stream.getSource();
962 FramedStream stream = connection.newStream(headerEntries("b", "banana"), true, true);
963 Sink sink = stream.getSink();
965 stream.writeTimeout().timeout(500, TimeUnit.MILLISECONDS);
986 // Set the peer's receive window to 5 bytes. Give the stream 5 bytes back, so only the
1003 FramedStream stream = connection.newStream(headerEntries("b", "banana"), true, true);
1005 Sink sink = stream.getSink();
1006 stream.writeTimeout().timeout(500, TimeUnit.MILLISECONDS);
1035 FramedStream stream = connection.newStream(headerEntries("b", "banana"), true, true);
1038 Sink sink = stream.getSink();
1062 FramedStream stream = connection.newStream(headerEntries("b", "banana"), true, true);
1064 assertEquals(headerEntries("a", "android", "c", "c3po"), stream.getResponseHeaders());
1085 FramedStream stream = connection.newStream(headerEntries("b", "banana"), true, true);
1088 stream.getResponseHeaders();
1091 assertEquals("stream was reset: PROTOCOL_ERROR", expected.getMessage());
1120 peer.acceptFrame(); // stream WINDOW UPDATE
1128 FramedStream stream = connection.newStream(headerEntries("b", "banana"), false, true);
1129 assertEquals(0, stream.unacknowledgedBytesRead);
1130 assertEquals(headerEntries("a", "android"), stream.getResponseHeaders());
1131 Source in = stream.getSource();
1148 assertTrue(windowUpdateStreamIds.contains(1)); // stream
1209 FramedStream stream = connection.newStream(headerEntries("b", "banana"), true, true);
1210 assertEquals(headerEntries("a", "android"), stream.getResponseHeaders());
1211 Source in = stream.getSource();
1216 assertEquals("stream was reset: PROTOCOL_ERROR", expected.getMessage());
1224 peer.acceptFrame(); // SYN_STREAM on stream 1
1226 peer.acceptFrame(); // DATA on stream 1
1228 peer.acceptFrame(); // SYN_STREAM on stream 2
1229 peer.acceptFrame(); // DATA on stream 2
1239 // Check that we've filled the window for both the stream and also the connection.
1249 // Another stream should be able to send data even though 1 is blocked.
1316 trailingCompressedBytes[11] = 1; // Set SPDY/3 stream ID to 3.
1324 FramedStream stream = connection.newStream(headerEntries("b", "banana"), true, true);
1325 assertEquals("a", stream.getResponseHeaders().get(0).name.utf8());
1326 assertEquals(length, stream.getResponseHeaders().get(0).value.size());
1327 assertStreamData("robot", stream.getSource());
