Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 131 for callArgs (0.23 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/platform/Jdk8WithJettyBootPlatform.kt

            return null
          } else if (methodName == "protocols" && callArgs.isEmpty()) {
            return protocols // Client advertises these protocols.
          } else if ((methodName == "selectProtocol" || methodName == "select") &&
            String::class.java == returnType && callArgs.size == 1 && callArgs[0] is List<*>
          ) {
            val peerProtocols = callArgs[0] as List<*>
            // Pick the first known protocol the peer advertises.
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 6K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/graph/AbstractDirectedNetworkConnections.java

        // (We're relying on callers to call this method only with an edge that's in the graph.)
        return requireNonNull(outEdgeMap.get(edge));
      }
    
      @Override
      public N removeInEdge(E edge, boolean isSelfLoop) {
        if (isSelfLoop) {
          checkNonNegative(--selfLoopCount);
        }
        N previousNode = inEdgeMap.remove(edge);
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 26 17:43:39 GMT 2021
    - 4.5K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/graph/AbstractUndirectedNetworkConnections.java

        return incidentEdges();
      }
    
      @Override
      public Set<E> outEdges() {
        return incidentEdges();
      }
    
      @Override
      public N adjacentNode(E edge) {
        // We're relying on callers to call this method only with an edge that's in the graph.
        return requireNonNull(incidentEdgeMap.get(edge));
      }
    
      @Override
      @CheckForNull
      public N removeInEdge(E edge, boolean isSelfLoop) {
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 26 17:43:39 GMT 2021
    - 2.7K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/Call.kt

      fun request(): Request
    
      /**
       * Invokes the request immediately, and blocks until the response can be processed or is in error.
       *
       * To avoid leaking resources callers should close the [Response] which in turn will close the
       * underlying [ResponseBody].
       *
       * ```java
       * // ensure the response (and underlying response body) is closed
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Wed Dec 20 23:27:07 GMT 2023
    - 3.6K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt

      fun metadata(): ByteString = metadata
    
      /**
       * Returns a new source that returns the same bytes as upstream. Returns null if this relay has
       * been closed and no further sources are possible. In that case callers should retry after
       * building a new relay with [.read].
       */
      fun newSource(): Source? {
        synchronized(this@Relay) {
          if (file == null) return null
          sourceCount++
        }
    
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 11.8K bytes
    - Viewed (0)
  6. tensorflow/c/experimental/filesystem/plugins/gcs/ram_file_block_cache_test.cc

    }
    
    TEST(RamFileBlockCacheTest, ParallelReads) {
      // This fetcher won't respond until either `callers` threads are calling it
      // concurrently (at which point it will respond with success to all callers),
      // or 10 seconds have elapsed (at which point it will respond with an error).
      const int callers = 4;
      BlockingCounter counter(callers);
      auto fetcher = [&counter](const string& filename, size_t offset, size_t n,
    C++
    - Registered: Tue Apr 23 12:39:09 GMT 2024
    - Last Modified: Fri Oct 15 03:16:57 GMT 2021
    - 23.2K bytes
    - Viewed (0)
  7. istioctl/pkg/admin/istiodconfig_test.go

    	switch request.Method {
    	case http.MethodGet:
    		_, _ = writer.Write([]byte(getResponse))
    	}
    }
    
    func adsHandler(writer http.ResponseWriter, request *http.Request) {
    	const getResponse = `{"name":"ads","description":"ads debugging","output_level":"info","stack_trace_level":"none","log_callers":false}`
    
    	switch request.Method {
    	case http.MethodGet:
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Thu Jun 15 15:02:17 GMT 2023
    - 6.2K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java

           *
           * Fortunately, exceptions rarely contain references to expensive resources.
           */
    
          //
          seenExceptionsLocal = newConcurrentHashSet();
          /*
           * Other handleException() callers may see this as soon as we publish it. We need to populate
           * it with the initial failure before we do, or else they may think that the initial failure
           * has never been seen before.
           */
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Dec 14 20:35:03 GMT 2023
    - 8.5K bytes
    - Viewed (0)
  9. okhttp-urlconnection/src/main/kotlin/okhttp3/JavaNetCookieJar.kt

     * A cookie jar that delegates to a [java.net.CookieHandler].
     *
     * This implementation delegates everything to [okhttp3.java.net.cookiejar.JavaNetCookieJar], which
     * conforms to the package-naming limitations of JPMS.
     *
     * Callers should prefer to use [okhttp3.java.net.cookiejar.JavaNetCookieJar] directly.
     */
    class JavaNetCookieJar private constructor(
      delegate: okhttp3.java.net.cookiejar.JavaNetCookieJar,
    ) : CookieJar by delegate {
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 1.3K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/MultipartReader.kt

    import okio.BufferedSource
    import okio.ByteString.Companion.encodeUtf8
    import okio.Options
    import okio.Source
    import okio.Timeout
    import okio.buffer
    
    /**
     * Reads a stream of [RFC 2046][rfc_2046] multipart body parts. Callers read parts one-at-a-time
     * until [nextPart] returns null. After calling [nextPart] any preceding parts should not be read.
     *
     * Typical use loops over the parts in sequence:
     *
     * ```kotlin
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 7.1K bytes
    - Viewed (0)
Back to top