Lines Matching defs:source
45 result.source = buffer;
59 result.source = new RealBufferedSource(buffer);
73 result.source = new RealBufferedSource(new ForwardingSource(buffer) {
92 BufferedSource source;
114 private BufferedSource source;
119 source = pipe.source;
124 assertEquals(0xab, source.readByte() & 0xff);
125 assertEquals(0xcd, source.readByte() & 0xff);
126 assertTrue(source.exhausted());
133 assertEquals((short) 0xabcd, source.readShort());
134 assertEquals((short) 0xef01, source.readShort());
135 assertTrue(source.exhausted());
142 assertEquals((short) 0xcdab, source.readShortLe());
143 assertEquals((short) 0x10ef, source.readShortLe());
144 assertTrue(source.exhausted());
150 source.skip(Segment.SIZE - 1);
151 assertEquals((short) 0xabcd, source.readShort());
152 assertTrue(source.exhausted());
160 assertEquals(0xabcdef01, source.readInt());
161 assertEquals(0x87654321, source.readInt());
162 assertTrue(source.exhausted());
170 assertEquals(0x10efcdab, source.readIntLe());
171 assertEquals(0x21436587, source.readIntLe());
172 assertTrue(source.exhausted());
180 source.skip(Segment.SIZE - 3);
181 assertEquals(0xabcdef01, source.readInt());
182 assertTrue(source.exhausted());
191 assertEquals(0xabcdef1087654321L, source.readLong());
192 assertEquals(0x3647586912233445L, source.readLong());
193 assertTrue(source.exhausted());
202 assertEquals(0x2143658710efcdabL, source.readLongLe());
203 assertEquals(0x4534231269584736L, source.readLongLe());
204 assertTrue(source.exhausted());
213 source.skip(Segment.SIZE - 7);
214 assertEquals(0xabcdef0187654321L, source.readLong());
215 assertTrue(source.exhausted());
219 source.buffer().writeUtf8("abc");
223 assertEquals(6, source.readAll(sink));
225 assertTrue(source.exhausted());
230 assertEquals(0, source.readAll(mockSink));
231 assertTrue(source.exhausted());
238 assertEquals(-1, source.read(sink, 10));
240 assertTrue(source.exhausted());
249 assertEquals(-1, source.read(sink, 0));
251 assertTrue(source.exhausted());
257 source.readFully(sink, 9999);
259 assertEquals("a", source.readUtf8());
266 source.readFully(sink, 5);
271 // Verify we read all that we could from the source.
283 source.readFully(sink);
292 source.readFully(sink);
297 // Verify we read all that we could from the source.
305 int read = source.read(sink);
321 int read = source.read(sink);
337 int read = source.read(sink, 2, 3);
352 assertByteArraysEquals(string.getBytes(UTF_8), source.readByteArray());
357 assertEquals("[97, 98, 99]", Arrays.toString(source.readByteArray(3)));
358 assertEquals("d", source.readUtf8(1));
363 assertEquals("abcd" + repeat('e', Segment.SIZE), source.readByteString().utf8());
368 assertEquals("abc", source.readByteString(3).utf8());
369 assertEquals("d", source.readUtf8(1));
376 assertEquals("v??läs?", source.readString(7 * 4, Charset.forName("utf-32")));
383 assertEquals("v??läs??rapt?r", source.readString(Charset.forName("utf-32")));
388 source.skip(Segment.SIZE - 1);
389 assertEquals("aa", source.readUtf8(2));
394 assertEquals(repeat('a', Segment.SIZE), source.readUtf8(Segment.SIZE));
399 assertEquals(repeat('a', Segment.SIZE + 10), source.readUtf8(Segment.SIZE + 10));
404 assertEquals(repeat('a', Segment.SIZE * 2), source.readUtf8());
411 source.skip(1);
412 assertEquals('b', source.readByte() & 0xff);
413 source.skip(Segment.SIZE - 2);
414 assertEquals('b', source.readByte() & 0xff);
415 source.skip(1);
416 assertTrue(source.exhausted());
423 source.skip(2);
431 assertEquals(-1, source.indexOf((byte) 'a'));
435 assertEquals(0, source.indexOf((byte) 'a'));
436 assertEquals(-1, source.indexOf((byte) 'b'));
440 assertEquals(0, source.indexOf((byte) 'a'));
441 assertEquals(1, source.indexOf((byte) 'b'));
442 assertEquals(-1, source.indexOf((byte) 'c'));
445 source.skip(2); // b...b
446 assertEquals(-1, source.indexOf((byte) 'a'));
447 assertEquals(0, source.indexOf((byte) 'b'));
448 assertEquals(-1, source.indexOf((byte) 'c'));
452 assertEquals(-1, source.indexOf((byte) 'a'));
453 assertEquals(0, source.indexOf((byte) 'b'));
454 assertEquals(Segment.SIZE - 3, source.indexOf((byte) 'c'));
457 source.skip(2); // b...bc
458 assertEquals(-1, source.indexOf((byte) 'a'));
459 assertEquals(0, source.indexOf((byte) 'b'));
460 assertEquals(Segment.SIZE - 5, source.indexOf((byte) 'c'));
464 assertEquals(Segment.SIZE - 4, source.indexOf((byte) 'd'));
465 assertEquals(-1, source.indexOf((byte) 'e'));
470 assertEquals(-1, source.indexOf((byte) 'a', 1));
471 assertEquals(15, source.indexOf((byte) 'b', 15));
475 assertEquals(-1, source.indexOf(ByteString.encodeUtf8("flop")));
478 assertEquals(5, source.indexOf(ByteString.encodeUtf8("flop")));
479 source.readUtf8(); // Clear stream.
483 assertEquals(3, source.indexOf(ByteString.encodeUtf8("hi hi hey")));
487 assertEquals(-1, source.indexOf(ByteString.encodeUtf8("flop"), 1));
490 assertEquals(10, source.indexOf(ByteString.encodeUtf8("flop"), 1));
491 source.readUtf8(); // Clear stream
495 assertEquals(6, source.indexOf(ByteString.encodeUtf8("hi hi hey"), 1));
500 source.indexOf(ByteString.of());
506 source.indexOf(ByteString.encodeUtf8("hi"), -1);
515 assertEquals(0, source.indexOfElement(ByteString.encodeUtf8("DEFGaHIJK")));
516 assertEquals(1, source.indexOfElement(ByteString.encodeUtf8("DEFGHIJKb")));
517 assertEquals(Segment.SIZE + 1, source.indexOfElement(ByteString.encodeUtf8("cDEFGHIJK")));
518 assertEquals(1, source.indexOfElement(ByteString.encodeUtf8("DEFbGHIc")));
519 assertEquals(-1L, source.indexOfElement(ByteString.encodeUtf8("DEFGHIJK")));
520 assertEquals(-1L, source.indexOfElement(ByteString.encodeUtf8("")));
525 assertEquals(-1, source.indexOfElement(ByteString.encodeUtf8("DEFGaHIJK"), 1));
526 assertEquals(15, source.indexOfElement(ByteString.encodeUtf8("DEFGHIJKb"), 15));
531 assertTrue(source.request(Segment.SIZE + 2));
532 assertFalse(source.request(Segment.SIZE + 3));
537 source.require(Segment.SIZE + 2);
539 source.require(Segment.SIZE + 3);
547 InputStream in = source.inputStream();
571 InputStream in = source.inputStream();
585 InputStream in = source.inputStream();
592 InputStream in = source.inputStream();
601 InputStream in = source.inputStream();
632 long actual = source.readHexadecimalUnsignedLong();
638 source.skip(Segment.SIZE - 8);
639 assertEquals(-1, source.readHexadecimalUnsignedLong());
645 source.readHexadecimalUnsignedLong();
655 source.readHexadecimalUnsignedLong();
665 source.readHexadecimalUnsignedLong();
685 long actual = source.readDecimalLong();
687 assertEquals("zzz", source.readUtf8());
693 source.skip(Segment.SIZE - 8);
694 assertEquals(1234567890123456L, source.readDecimalLong());
695 assertEquals("zzz", source.readUtf8());
701 source.readDecimalLong();
711 source.readDecimalLong();
721 source.readDecimalLong();
731 source.readDecimalLong();
741 source.readDecimalLong();
749 assertEquals(0x7f, source.readUtf8CodePoint());
752 assertEquals(0x07ff, source.readUtf8CodePoint());
755 assertEquals(0xffff, source.readUtf8CodePoint());
758 assertEquals(0x10ffff, source.readUtf8CodePoint());
