addUnsafeNonAsciiAcceptsUnicodeValue() { L136: val headers = L137: Headers.Builder() L138: .addUnsafeNonAscii("header1", "valué1") L139: .build() L140: assertThat(headers.toString()).isEqualTo("header1: valué1\n") L141: } L142: L143: // Fails on JS, ClassCastException: Illegal cast L144: @Test fun ofMapThrowsOnNull() { L145: assertFailsWith<NullPointerException> { L146: (mapOf("User-Agent" to null) as Map<String, String>).toHeaders() L147: } L148: } L149: L150: @Test fun ...

private final Pattern pattern; L38: L39: /** L40: * Constructs a pattern file name filter object. L41: * L42: * @param patternStr the pattern string on which to filter file names L43: * @throws PatternSyntaxException if pattern compilation fails (runtime) L44: */ L45: public PatternFilenameFilter(String patternStr) { L46: this(Pattern.compile(patternStr)); L47: } L48: L49: /** L50: * Constructs a pattern file name filter object. L51: * L52: * @param pattern the pattern on which...

@Test L448: fun statementStartsAndStops() { L449: val called = AtomicBoolean() L450: val statement = L451: server.apply( L452: object : Statement() { L453: override fun evaluate() { L454: called.set(true) L455: server.url("/").toUrl().openConnection().connect() L456: } L457: }, L458: Description.EMPTY, L459: ) L460: statement.evaluate() L461: assertThat(called.get()).isTrue() L462: try { L463: server.url("/...

/** 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(), ' '.code.toByte()) L351: private...

if (isBrowser && navigator.userAgent.indexOf(longerTimeoutBrowsers[i]) >= 0) {\n return 1;\n }\n }\n return 0;\n}());\n\nexport function microtaskDebounce(fn) {\n let called = false\n return () => {\n if (called) {\n return\n }\n called = true\n window.Promise.resolve().then(() => {\n called = false\n fn()\n })\n }\n}\n\nexport function taskDebounce(fn) {\n let scheduled = false;\n return () => {\n if (!scheduled) {\n scheduled = true;\n setTimeout(()...

until <a L103: * href="http://bugs.sun.com/bugdatabase/view_bug.do?bug_id=6409434">Sun bug 6409434</a> is fixed. L104: * It's unclear whether nulls were to be permitted or forbidden, but presumably the eventual fix L105: * will be to permit them, as it seems more likely that code would depend on that behavior than on L106: * the other. Thus, we say the bug is in add(), which fails to support null. L107: */ L108: @J2ktIncompatible L109: @GwtIncompatible // reflection L110: public static...

until <a L103: * href="http://bugs.sun.com/bugdatabase/view_bug.do?bug_id=6409434">Sun bug 6409434</a> is fixed. L104: * It's unclear whether nulls were to be permitted or forbidden, but presumably the eventual fix L105: * will be to permit them, as it seems more likely that code would depend on that behavior than on L106: * the other. Thus, we say the bug is in add(), which fails to support null. L107: */ L108: @J2ktIncompatible L109: @GwtIncompatible // reflection L110: public static...

actually copying the data when it is L226: * safe to do so. The exact circumstances under which a copy will or will not be performed are L227: * undocumented and subject to change. L228: * L229: * <p>This method is not type-safe, as it may be called on elements that are not mutually L230: * comparable. L231: * L232: * @throws ClassCastException if the elements are not mutually comparable L233: * @throws NullPointerException if any of {@code elements} is null L234: */ L235: public static...

Executors.newCachedThreadPool(); L175: L176: int listenerCount = 20; L177: CountDownLatch listenerLatch = new CountDownLatch(listenerCount); L178: L179: // Test that listeners added both before and after the value is available L180: // get called correctly. L181: for (int i = 0; i < 20; i++) { L182: L183: // Right in the middle start up a thread to close the latch. L184: if (i == 10) { L185: new Thread(() -> latch.countDown()).start(); L186: } L187: L188: fut...

TLS extensions on `sslSocket` for `route`. L116: */ L117: open fun configureTlsExtensions( L118: sslSocket: SSLSocket, L119: hostname: String?, L120: protocols: List<@JvmSuppressWildcards Protocol>, L121: ) { L122: } L123: L124: /** Called after the TLS handshake to release resources allocated by [configureTlsExtensions]. */ L125: open fun afterHandshake(sslSocket: SSLSocket) { L126: } L127: L128: /** Returns the negotiated protocol, or null if no protocol was negotiated. */ L129:...