Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 16 for executor (0.08 sec)

  1. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

       *     exception itself.
       * @param executor the executor that runs {@code fallback} if the input fails
       */
      public <X extends Throwable> ClosingFuture<V> catching(
          Class<X> exceptionType, ClosingFunction<? super X, ? extends V> fallback, Executor executor) {
        return catchingMoreGeneric(exceptionType, fallback, executor);
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 23 15:26:56 UTC 2025
    - 97.8K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/ClosingFuture.java

       *     exception itself.
       * @param executor the executor that runs {@code fallback} if the input fails
       */
      public <X extends Throwable> ClosingFuture<V> catching(
          Class<X> exceptionType, ClosingFunction<? super X, ? extends V> fallback, Executor executor) {
        return catchingMoreGeneric(exceptionType, fallback, executor);
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 23 15:26:56 UTC 2025
    - 98.1K bytes
    - Viewed (0)
  3. okhttp/src/androidMain/baseline-prof.txt

    HSPLandroidx/arch/core/executor/ArchTaskExecutor;-><init>()V
    HSPLandroidx/arch/core/executor/ArchTaskExecutor;->getInstance()Landroidx/arch/core/executor/ArchTaskExecutor;
    HSPLandroidx/arch/core/executor/DefaultTaskExecutor$1;-><init>(Landroidx/arch/core/executor/DefaultTaskExecutor;)V
    HSPLandroidx/arch/core/executor/DefaultTaskExecutor;-><init>()V
    HSPLandroidx/arch/core/executor/DefaultTaskExecutor;->isMainThread()Z
    HSPLandroidx/arch/core/executor/TaskExecutor;-><init>()V
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Dec 30 23:28:56 UTC 2024
    - 127.9K bytes
    - Viewed (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt

            .body("def")
            .throttleBody(1, 750, TimeUnit.MILLISECONDS)
            .build(),
        )
        val call = client.newCall(Request(server.url("/a")))
        val executor = Executors.newSingleThreadExecutor()
        val result = executor.submit<Response?> { call.execute() }
        Thread.sleep(100) // wait for it to go in flight.
        call.cancel()
        assertFailsWith<IOException> {
          result.get()!!.body.bytes()
        }
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 146.6K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/opensearch/client/SearchEngineClient.java

                final ActionType<Response> action, final Request request) {
            return client.execute(action, request);
        }
    
        /**
         * Executes an action asynchronously with a callback.
         *
         * @param <Request>  the request type
         * @param <Response> the response type
         * @param action     the action to execute
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sun Aug 31 08:19:00 UTC 2025
    - 121.9K bytes
    - Viewed (0)
  6. cmd/object-handlers_test.go

    	if err != nil {
    		t.Fatalf("Failed to create HTTP request for NewMultipart Request: <ERROR> %v", err)
    	}
    	// Since `apiRouter` satisfies `http.Handler` it has a ServeHTTP to execute the logic of the handler.
    	// Call the ServeHTTP to executes the registered handler.
    	apiRouter.ServeHTTP(rec, req)
    	// Assert the response code with the expected status.
    	if rec.Code != http.StatusOK {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 163.1K bytes
    - Viewed (0)
  7. okhttp/src/jvmTest/kotlin/okhttp3/CacheTest.kt

        client.newCall(request).execute().use {
          it.body.bytes()
        }
        return client.newCall(request).execute()
      }
    
      private operator fun get(url: HttpUrl): Response {
        val request =
          Request
            .Builder()
            .url(url)
            .build()
        return client.newCall(request).execute()
      }
    
      private fun writeFile(
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 16 09:39:51 UTC 2025
    - 113.6K bytes
    - Viewed (0)
  8. src/main/webapp/js/admin/popper.min.js.map

          .map(name => ({\n        name,\n        ...this.options.modifiers[name],\n      }))\n      // sort the modifiers by order\n      .sort((a, b) => a.order - b.order);\n\n    // modifiers have the ability to execute arbitrary code when Popper.js get inited\n    // such code is executed in the same order of its modifier\n    // they could add new properties to their options configuration\n    // BE AWARE: don't add options to `options.modifiers.name` but to `modifierOptions`!\n    this.modifie...
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Oct 26 01:49:09 UTC 2024
    - 120.9K bytes
    - Viewed (0)
  9. cmd/server_test.go

    	c.Assert(err, nil)
    
    	// execute the HTTP request.
    	response, err = s.client.Do(request)
    
    	c.Assert(err, nil)
    	c.Assert(response.StatusCode, http.StatusOK)
    
    	request, err = newTestSignedRequest(http.MethodGet, getGetObjectURL(s.endPoint, bucketName, "my-object-directory/"),
    		0, nil, s.accessKey, s.secretKey, s.signer)
    	c.Assert(err, nil)
    
    	// execute the HTTP request.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118.1K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/io/testdata/alice_in_wonderland.txt

    looking anxiously about as it went, as if it had lost something;
    and she heard it muttering to itself `The Duchess!  The Duchess!
    Oh my dear paws!  Oh my fur and whiskers!  She'll get me
    executed, as sure as ferrets are ferrets!  Where CAN I have
    dropped them, I wonder?'  Alice guessed in a moment that it was
    looking for the fan and the pair of white kid gloves, and she
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Apr 21 02:27:51 UTC 2017
    - 145.2K bytes
    - Viewed (0)
Back to top