Search Options

Results per page
Sort
Preferred Languages
Advance

Results 331 - 340 of 744 for Executed (0.07 sec)

  1. guava/src/com/google/common/util/concurrent/ListenableFutureTask.java

       * Callable}.
       *
       * @param callable the callable task
       * @since 10.0
       */
      public static <V extends @Nullable Object> ListenableFutureTask<V> create(Callable<V> callable) {
        return new ListenableFutureTask<>(callable);
      }
    
      /**
       * Creates a {@code ListenableFutureTask} that will upon running, execute the given {@code
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/TimeLimiter.java

       * propagated. If, on the other hand, the time limit is reached, we attempt to abort the call to
       * the target, and throw a {@link TimeoutException} to the caller.
       *
       * @param callable the Callable to execute
       * @param timeoutDuration with timeoutUnit, the maximum length of time to wait
       * @param timeoutUnit with timeoutDuration, the maximum length of time to wait
       * @return the result returned by the Callable
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 15.3K bytes
    - Viewed (0)
  3. container-tests/src/test/java/okhttp3/containers/BasicMockServerTest.kt

                .withQueryStringParameter("name", "peter"),
            )
            .respond(response().withBody("Peter the person!"))
    
          val response = client.newCall(Request((mockServer.endpoint + "/person?name=peter").toHttpUrl())).execute()
    
          assertThat(response.body.string()).contains("Peter the person")
        }
      }
    
      @Test
      fun testHttpsRequest() {
        MockServerClient(mockServer.host, mockServer.serverPort).use { mockServerClient ->
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Fri Apr 05 03:30:42 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  4. okhttp-android/src/test/kotlin/okhttp3/android/AndroidLoggingTest.kt

            level = HttpLoggingInterceptor.Level.BASIC
          }
    
        val client = clientBuilder.addInterceptor(interceptor).build()
    
        try {
          client.newCall(request).execute()
        } catch (uhe: UnknownHostException) {
          // expected
        }
    
        val logs = ShadowLog.getLogsForTag("testHttpLoggingInterceptor")
        assertThat(logs.map { it.type }).containsOnly(Log.INFO)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 01 11:07:32 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/ListenerCallQueue.java

       * case of an error.
       *
       * @param event the callback to execute on {@link #dispatch}
       */
      public void enqueue(Event<L> event) {
        enqueueHelper(event, event);
      }
    
      /**
       * Enqueues an event to be run on currently known listeners, with a label.
       *
       * @param event the callback to execute on {@link #dispatch}
       * @param label a description of the event to use in the case of an error
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Dec 13 19:45:20 UTC 2023
    - 8.2K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/app/web/admin/dashboard/AdminDashboardAction.java

    import org.codelibs.fess.annotation.Secured;
    import org.codelibs.fess.api.engine.SearchEngineApiManager;
    import org.codelibs.fess.app.web.base.FessAdminAction;
    import org.codelibs.fess.util.RenderDataUtil;
    import org.lastaflute.web.Execute;
    import org.lastaflute.web.response.HtmlResponse;
    import org.lastaflute.web.ruts.process.ActionRuntime;
    
    import jakarta.annotation.Resource;
    
    /**
     * @author shinsuke
     * @author Keiichi Watanabe
     */
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  7. samples/guide/src/main/java/okhttp3/recipes/kt/PerCallSettings.kt

        // Copy to customize OkHttp for this request.
        val client1 =
          client.newBuilder()
            .readTimeout(500, TimeUnit.MILLISECONDS)
            .build()
        try {
          client1.newCall(request).execute().use { response ->
            println("Response 1 succeeded: $response")
          }
        } catch (e: IOException) {
          println("Response 1 failed: $e")
        }
    
        // Copy to customize OkHttp for this request.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/query/BoostQueryCommand.java

        }
    
        @Override
        public QueryBuilder execute(final QueryContext context, final Query query, final float boost) {
            if (query instanceof final BoostQuery boostQuery) {
                if (logger.isDebugEnabled()) {
                    logger.debug("{}:{}", query, boost);
                }
                return getQueryProcessor().execute(context, boostQuery.getQuery(), boostQuery.getBoost());
            }
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/app/web/admin/storage/AdminStorageAction.java

        }
    
        @Override
        protected String getActionRole() {
            return ROLE;
        }
    
        @Execute
        @Secured({ ROLE, ROLE + VIEW })
        public HtmlResponse index() {
            saveToken();
            return asListHtml(StringUtil.EMPTY);
        }
    
        @Execute
        @Secured({ ROLE, ROLE + VIEW })
        public ActionResponse list(final OptionalThing<String> id) {
            saveToken();
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java

        assertFalse(task.isCancelled());
    
        // Start the task to put it in the RUNNING state.  Have to use a separate
        // thread because the task will block on the task latch after unblocking
        // the run latch.
        exec.execute(task);
        runLatch.await();
        assertEquals(1, listenerLatch.getCount());
        assertFalse(task.isDone());
        assertFalse(task.isCancelled());
    
        // Finish the task by unblocking the task latch.  Then wait for the
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 4.7K bytes
    - Viewed (0)
Back to top