Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for onReset (0.04 sec)

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

    import okio.BufferedSource
    
    /**
     * [HTTP/2][Protocol.HTTP_2] only. Processes server-initiated HTTP requests on the client.
     * Implementations must quickly dispatch callbacks to avoid creating a bottleneck.
     *
     * 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)
     *
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 3.6K bytes
    - Viewed (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt

              }
            }
          }
        }
      }
    
      internal fun pushResetLater(
        streamId: Int,
        errorCode: ErrorCode,
      ) {
        pushQueue.execute("$connectionName[$streamId] onReset") {
          pushObserver.onReset(streamId, errorCode)
          withLock {
            currentPushRequests.remove(streamId)
          }
        }
      }
    
      /** Listener of streams and settings initiated by the peer. */
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 31.8K bytes
    - Viewed (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt

        ): Boolean {
          events.add(AssertionError("onData"))
          notifyAll()
          return false
        }
    
        @Synchronized override fun onReset(
          streamId: Int,
          errorCode: ErrorCode,
        ) {
          events.add(AssertionError("onReset"))
          notifyAll()
        }
      }
    
      companion object {
        fun roundUp(
          num: Int,
          divisor: Int,
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 75.5K bytes
    - Viewed (0)
  4. src/test/java/jcifs/internal/smb2/Smb2EncryptionContextTest.java

            int count = 10000; // Test with larger number for collision detection
            Set<String> nonceSet = new HashSet<>();
    
            // When
            for (int i = 0; i < count; i++) {
                byte[] nonce = encryptionContext.generateNonce();
                String nonceHex = bytesToHex(nonce);
                boolean added = nonceSet.add(nonceHex);
                assertTrue(added, "Nonce collision detected at iteration " + i);
            }
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 44.1K bytes
    - Viewed (0)
  5. fess-crawler/src/main/java/org/codelibs/fess/crawler/transformer/impl/XpathTransformer.java

     * to parse the HTML content, evaluate XPath expressions, and generate the XML output.
     * </p>
     * <p>
     * The class supports various XPath result types, including BOOLEAN, NUMBER, STRING, NODESET, and NODE.
     * It also provides options to trim whitespace from extracted values and to specify the character encoding for the output.
     * </p>
     * <p>
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 13.1K bytes
    - Viewed (0)
  6. fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/HtmlExtractor.java

                    return new String[] { d.toString() };
                case STRING:
                    final String str = (String) xObj.value();
                    return new String[] { str.trim() };
                case NODESET:
                    final XPathNodes nodeList = (XPathNodes) xObj.value();
                    final List<String> strList = new ArrayList<>();
                    for (int i = 0; i < nodeList.size(); i++) {
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 9.3K bytes
    - Viewed (0)
Back to top