Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 8 of 8 for onRead (0.04 seconds)

  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/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)
  6. src/main/webapp/js/admin/plugins/form-validator/security.js

    row new Error("reCaptcha API can not be loaded by hand, delete reCaptcha API snippet.");if(!a.formUtils.hasLoadedGrecaptcha&&a('[data-validation~="recaptcha"]',c).length){a.formUtils.hasLoadedGrecaptcha=!0;var e="//www.google.com/recaptcha/api.js?onload=reCaptchaLoaded&render=explicit"+(d.lang?"&hl="+d.lang:""),f=document.createElement("script");f.type="text/javascript",f.async=!0,f.defer=!0,f.src=e,document.getElementsByTagName("body")[0].appendChild(f)}};b.reCaptchaLoaded=function(b){b&&"object"==typeof...
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Mon Jan 01 05:12:47 GMT 2018
    - 10.5K bytes
    - Click Count (1)
  7. 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)
  8. src/main/webapp/js/admin/plugins/form-validator/jquery.form-validator.min.js

    ement("SCRIPT");"function"==typeof define&&define.amd?require([e+(".dev.js"===e.slice(-7)?h:"")],g):(f.type="text/javascript",f.onload=g,f.src=e+(".dev.js"===e.slice(-7)?h:""),f.onerror=function(){a.formUtils.warn("Unable to load form validation module "+e,!0),g()},f.onreadystatechange=function(){"complete"!==this.readyState&&"loaded"!==this.readyState||(g(),this.onload=null,this.onreadystatechange=null)},i.appendChild(f))}})};if(c)e(b,c);else{var f=function(){var c=!1;return a('script[src*="for...
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Mon Jan 01 05:12:47 GMT 2018
    - 32.8K bytes
    - Click Count (0)
Back to Top