Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 13 for onRead (0.19 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. okhttp/src/jvmTest/kotlin/okhttp3/InterceptorOverridesTest.kt

          }
    
          OverrideParam.ReadTimeout -> {
            client =
              client
                .newBuilder()
                .socketFactory(
                  DelayingSocketFactory(onRead = {
                    Thread.sleep(100L)
                  }),
                ).build()
    
            overrideBadImplementation(override = override.override, testItFails = testItFails)
          }
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Mar 11 02:37:00 GMT 2026
    - 28.8K bytes
    - Click Count (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/RealWebSocket.kt

      @Throws(IOException::class)
      fun loopReader(response: Response) {
        try {
          listener.onOpen(this@RealWebSocket, response)
          while (receivedCloseCode == -1) {
            // This method call results in one or more onRead* methods being called on this thread.
            reader!!.processNextFrame()
          }
        } catch (e: Exception) {
          failWebSocket(e = e)
        } finally {
          finishReader()
        }
      }
    
      /**
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 21.6K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/io/CharStreams.java

        checkNotNull(from);
        checkNotNull(to);
        char[] buf = new char[DEFAULT_BUF_SIZE];
        int nRead;
        long total = 0;
        while ((nRead = from.read(buf)) != -1) {
          to.append(buf, 0, nRead);
          total += nRead;
        }
        return total;
      }
    
      /**
       * Copies all characters between the {@link Reader} and {@link Writer} objects. Does not close or
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Sep 29 13:56:24 GMT 2025
    - 11.9K bytes
    - Click Count (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt

        override fun close() {
          if (closed) return
    
          if (bytesRemaining != 0L &&
            !discard(ExchangeCodec.DISCARD_STREAM_TIMEOUT_MILLIS, MILLISECONDS)
          ) {
            carrier.noNewExchanges() // Unread bytes remain on the stream.
            responseBodyComplete(TRAILERS_RESPONSE_BODY_TRUNCATED)
          }
    
          closed = true
        }
      }
    
      /** An HTTP body with alternating chunk sizes and chunk bodies. */
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 17.6K bytes
    - Click Count (7)
  5. build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/docbook/BasicJavadocLexer.java

                        text.append(scanner.getFirst());
                        scanner.next();
                    }
                }
    
                visitor.onText(text.toString());
            }
            visitor.onEnd();
        }
    
        private void skipComment() {
            scanner.next(4);
            while (!scanner.isEmpty() && !scanner.lookingAt(END_HTML_COMMENT)) {
                scanner.next();
            }
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Mon Aug 19 15:07:24 GMT 2024
    - 7.1K bytes
    - Click Count (0)
  6. build-logic/documentation/src/main/groovy/gradlebuild/docs/ReleaseNotesTransformer.java

                    "                <img src=\"https://fast.wistia.com/embed/medias/$2/swatch\" style=\"filter:blur(5px);height:100%;object-fit:contain;width:100%;\" alt=\"$1\" aria-hidden=\"true\" onload=\"this.parentNode.style.opacity=1;\" /> \n" +
                    "        </div></div></div></div> \n" +
                    "    </div> \n" +
                    "  </div> \n" +
                    "</details>");
    
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Tue Mar 03 01:59:51 GMT 2026
    - 11.3K bytes
    - Click Count (0)
  7. src/main/webapp/js/admin/popper.min.js.map

    their options configuration\n    // BE AWARE: don't add options to `options.modifiers.name` but to `modifierOptions`!\n    this.modifiers.forEach(modifierOptions => {\n      if (modifierOptions.enabled && isFunction(modifierOptions.onLoad)) {\n        modifierOptions.onLoad(\n          this.reference,\n          this.popper,\n          this.options,\n          modifierOptions,\n          this.state\n        );\n      }\n    });\n\n    // fire the first update to position the popper in the right place\n...
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Oct 26 01:49:09 GMT 2024
    - 120.9K bytes
    - Click Count (0)
  8. src/main/webapp/js/admin/popper.min.js

    },r.modifiers?r.modifiers[e]:{})}),this.modifiers=Object.keys(this.options.modifiers).map(function(e){return le({name:e},i.options.modifiers[e])}).sort(function(e,t){return e.order-t.order}),this.modifiers.forEach(function(t){t.enabled&&e(t.onLoad)&&t.onLoad(i.reference,i.popper,i.options,t,i.state)}),this.update();var p=this.options.eventsEnabled;p&&this.enableEventListeners(),this.state.eventsEnabled=p}return de(t,[{key:'update',value:function(){return k.call(this)}},{key:'destroy',value:function(){return...
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Oct 26 01:49:09 GMT 2024
    - 20.7K bytes
    - Click Count (0)
  9. android/guava-tests/test/com/google/common/collect/MapsTest.java

        assertThat(map.get("five")).isNull();
        assertThat(map.entrySet())
            .containsExactly(mapEntry("one", 3), mapEntry("three", 5), mapEntry("two", 3))
            .inOrder();
        assertThat(map.tailMap("onea").entrySet())
            .containsExactly(mapEntry("three", 5), mapEntry("two", 3))
            .inOrder();
        assertThat(map.subMap("one", "two").entrySet())
            .containsExactly(mapEntry("one", 3), mapEntry("three", 5))
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 63.2K bytes
    - Click Count (0)
  10. src/main/webapp/js/admin/jquery-3.7.1.min.js

    st"),e)r.setRequestHeader(n,e[n]);o=function(e){return function(){o&&(o=a=r.onload=r.onerror=r.onabort=r.ontimeout=r.onreadystatechange=null,"abort"===e?r.abort():"error"===e?"number"!=typeof r.status?t(0,"error"):t(r.status,r.statusText):t(Yt[r.status]||r.status,r.statusText,"text"!==(r.responseType||"text")||"string"!=typeof r.responseText?{binary:r.response}:{text:r.responseText},r.getAllResponseHeaders()))}},r.onload=o(),a=r.onerror=r.ontimeout=o("error"),void 0!==r.onabort?r.onabort=a:r.onr...
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Oct 26 01:07:52 GMT 2024
    - 85.5K bytes
    - Click Count (1)
Back to Top