"multipart/parallel".toMediaType() L341: L342: /** L343: * The media-type multipart/form-data follows the rules of all multipart MIME data streams as L344: * outlined in RFC 2046. In forms, there are a series of fields to be supplied by the user who L345: * fills out the form. Each field has a name. Within a given form, the names are unique. L346: */ L347: @JvmField L348: val FORM = "multipart/form-data".toMediaType() L349: L350: private val COLONSPACE = byteArrayOf(':'.code.toByte(),...

L258: } L259: } L260: } L261: L262: internal data class Message( L263: val bytes: ByteString? = null, L264: val string: String? = null, L265: ) L266: L267: internal data class Ping( L268: val payload: ByteString, L269: ) L270: L271: internal data class Pong( L272: val payload: ByteString, L273: ) L274: L275: internal data class Closing( L276: val code: Int, L277: val reason: String, L278: ) L279: L280: internal data class Closed( L281: val code: Int, L282: val...

00:00:00] << 0x00000000 4 WINDOW_UPDATE L33:[2020-01-01 00:00:00] >> 0x00000000 0 SETTINGS ACK L34:[2020-01-01 00:00:00] << 0x00000003 322 HEADERS END_HEADERS L35:[2020-01-01 00:00:00] << 0x00000003 288 DATA L36:[2020-01-01 00:00:00] << 0x00000003 0 DATA END_STREAM L37:[2020-01-01 00:00:00] << 0x00000000 8 GOAWAY L38:[2020-01-01 00:00:05] << 0x00000000 8 GOAWAY L39:``` L40: L41:### Task Runner Logging L42: L43:This logs task enqueues, starts, and finishes....

L46:@DoNotMock("Implement with a lambda") L47:@ElementTypesAreNonnullByDefault L48:public interface Funnel<T extends @Nullable Object> extends Serializable { L49: L50: /** L51: * Sends a stream of data from the {@code from} object into the sink {@code into}. There is no L52: * requirement that this data be complete enough to fully reconstitute the object later. L53: * L54: * @since 12.0 (in Guava 11.0, {@code PrimitiveSink} was named {@code Sink}) L55: */ L56: void funnel(@ParametricNullness...

AbstractIteratorTest extends TestCase { L42: L43: public void testDefaultBehaviorOfNextAndHasNext() { L44: L45: // This sample AbstractIterator returns 0 on the first call, 1 on the L46: // second, then signals that it's reached the end of the data L47: Iterator<Integer> iter = L48: new AbstractIterator<Integer>() { L49: private int rep; L50: L51: @Override L52: public @Nullable Integer computeNext() { L53: switch (rep++) { L54: case...

AbstractIteratorTest extends TestCase { L42: L43: public void testDefaultBehaviorOfNextAndHasNext() { L44: L45: // This sample AbstractIterator returns 0 on the first call, 1 on the L46: // second, then signals that it's reached the end of the data L47: Iterator<Integer> iter = L48: new AbstractIterator<Integer>() { L49: private int rep; L50: L51: @Override L52: public @Nullable Integer computeNext() { L53: switch (rep++) { L54: case...

this cache should use to store. L86: */ L87:class DiskLruCache( L88: fileSystem: FileSystem, L89: /** Returns the directory where this cache stores its data. */ L90: val directory: Path, L91: private val appVersion: Int, L92: internal val valueCount: Int, L93: /** Returns the maximum number of bytes that this cache should use to store its data. */ L94: maxSize: Long, L95: /** Used for asynchronous journal rebuilds. */ L96: taskRunner: TaskRunner, L97:) : Closeable, Flushable { L98: internal...

plainTable = L39: FileSystem.RESOURCES.read(path) { L40: readPlainTextIdnaMappingTable() L41: } L42: table = plainTable L43: val data = buildIdnaMappingTableData(plainTable) L44: compactTable = L45: IdnaMappingTable( L46: sections = data.sections, L47: ranges = data.ranges, L48: mappings = data.mappings, L49: ) L50: } L51: L52: @Test fun regularMappings() { L53: assertThat("hello".map()).isEqualTo("hello") L54: assertThat("hello-wo...

factory, byte[] bytes, String suiteName, String caseDesc, Method method) { L116: super(factory, bytes, suiteName, caseDesc, method); L117: } L118: L119: @Override L120: public void setUp() throws IOException { L121: source = factory.createSource(data); L122: } L123: L124: public void testOpenStream() throws IOException { L125: InputStream in = source.openStream(); L126: try { L127: byte[] readBytes = ByteStreams.toByteArray(in); L128: assertExpectedBytes(readBytes); L129: }...

</button> L107: <c:if test="${editable}"> L108: <button type="button" class="btn btn-danger" name="delete" L109: data-toggle="modal" data-target="#confirmToDelete" L110: value="<la:message key="labels.crawling_info_button_delete" />"> L111: <em class="fa fa-trash"> L112: ...