Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 15 for onData (0.26 seconds)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/PushObserver.kt

     *
     * While [onReset] may occur at any time, the following callbacks are expected in order,
     * correlated by stream ID.
     *
     *  * [onRequest]
     *  * [onHeaders] (unless canceled)
     *  * [onData] (optional sequence of data frames)
     *
     * As a stream ID is scoped to a single HTTP/2 connection, implementations which target multiple
     * connections should expect repetition of stream IDs.
     *
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 3.6K bytes
    - Click Count (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt

        source.require(byteCount.toLong()) // Eagerly read the frame before firing client thread.
        source.read(buffer, byteCount.toLong())
        pushQueue.execute("$connectionName[$streamId] onData") {
          ignoreIoExceptions {
            val cancel = pushObserver.onData(streamId, buffer, byteCount, inFinished)
            if (cancel) writer.rstStream(streamId, ErrorCode.CANCEL)
            if (cancel || inFinished) {
              withLock {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 31.9K bytes
    - Click Count (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt

          events.add(responseHeaders)
          notifyAll()
          return false
        }
    
        @Synchronized override fun onData(
          streamId: Int,
          source: BufferedSource,
          byteCount: Int,
          last: Boolean,
        ): Boolean {
          events.add(AssertionError("onData"))
          notifyAll()
          return false
        }
    
        @Synchronized override fun onReset(
          streamId: Int,
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 75.5K bytes
    - Click Count (0)
  4. src/main/java/org/codelibs/core/misc/Base64Util.java

         * </p>
         *
         * @param inData
         *            The data to encode
         * @return The encoded data, or an empty string if the input is null or empty
         */
        public static String encode(final byte[] inData) {
            if (ArrayUtil.isEmpty(inData)) {
                return "";
            }
            return Base64.getEncoder().encodeToString(inData);
        }
    
        /**
         * Decodes data encoded in Base64.
    Created: Fri Apr 03 20:58:12 GMT 2026
    - Last Modified: Sat Nov 22 11:21:59 GMT 2025
    - 2.1K bytes
    - Click Count (0)
  5. cmd/xl-storage-format-utils.go

    }
    
    func getFileInfo(xlMetaBuf []byte, volume, path, versionID string, opts fileInfoOpts) (FileInfo, error) {
    	var fi FileInfo
    	var err error
    	var inData xlMetaInlineData
    	if buf, data, e := isIndexedMetaV2(xlMetaBuf); e != nil {
    		return FileInfo{}, e
    	} else if buf != nil {
    		inData = data
    		fi, err = buf.ToFileInfo(volume, path, versionID, true)
    		if len(buf) != 0 && errors.Is(err, errFileNotFound) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Aug 08 15:29:58 GMT 2024
    - 5.5K bytes
    - Click Count (0)
  6. internal/s3select/jstream/scratch.go

    // bytes returns the written contents of scratch buffer
    func (s *scratch) bytes() []byte { return s.data[0:s.fill] }
    
    // grow scratch buffer
    func (s *scratch) grow() {
    	ndata := make([]byte, cap(s.data)*2)
    	copy(ndata, s.data)
    	s.data = ndata
    }
    
    // append single byte to scratch buffer
    func (s *scratch) add(c byte) {
    	if s.fill+1 >= cap(s.data) {
    		s.grow()
    	}
    
    	s.data[s.fill] = c
    	s.fill++
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Sep 23 19:35:41 GMT 2024
    - 758 bytes
    - Click Count (0)
  7. docs/tr/docs/tutorial/cookie-params.md

    ///
    
    /// info | Bilgi
    
    **Tarayıcılar cookie'leri** özel şekillerde ve arka planda işlediği için, **JavaScript**'in onlara dokunmasına kolayca izin **vermezler**.
    
    `/docs` adresindeki **API docs UI**'a giderseniz, *path operation*'larınız için cookie'lerin **dokümantasyonunu** görebilirsiniz.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Fri Feb 13 12:41:38 GMT 2026
    - 1.7K bytes
    - Click Count (0)
  8. src/main/java/org/codelibs/fess/sso/entraid/EntraIdAuthenticator.java

                            logger.debug("member={}", memberOf);
                        }
                        String memberType = (String) memberOf.get("@odata.type");
                        if (memberType == null) {
                            logger.warn("@odata.type is null: {}", memberOf);
                            continue;
                        }
                        memberType = memberType.toLowerCase(Locale.ENGLISH);
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sun Mar 15 08:03:27 GMT 2026
    - 56.8K bytes
    - Click Count (0)
  9. docs/tr/docs/features.md

    * Veritabanları, frontend’ler vb. ile **taviz yok**; ancak hepsiyle kolay entegrasyon.
    
    ### Sınırsız "Plug-in" { #unlimited-plug-ins }
    
    Başka bir deyişle, onlara gerek yok; ihtiyaç duyduğunuz kodu import edin ve kullanın.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Fri Mar 20 07:53:17 GMT 2026
    - 10.1K bytes
    - Click Count (0)
  10. okhttp/src/jvmMain/resources/okhttp3/internal/publicsuffix/PublicSuffixDatabase.list

    no.it
    nobeoka.miyazaki.jp
    noboribetsu.hokkaido.jp
    nobushi.jp
    noda.chiba.jp
    noda.iwate.jp
    nodes.k8s.fr-par.scw.cloud
    nodes.k8s.nl-ams.scw.cloud
    nodes.k8s.pl-waw.scw.cloud
    nog.community
    nogata.fukuoka.jp
    nogi.tochigi.jp
    noheji.aomori.jp
    noho.st
    nohost.me
    noip.me
    noip.us
    nokia
    nom.ag
    nom.co
    nom.es
    nom.fr
    nom.io
    nom.km
    nom.mg
    nom.nc
    nom.ni
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue May 27 22:00:49 GMT 2025
    - 129.6K bytes
    - Click Count (3)
Back to Top