Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 30 for executed (0.04 sec)

  1. cmd/test-utils_test.go

    		}
    	}
    
    	// expected error response when the unsigned HTTP request is not permitted.
    	unsupportedSignature := getAPIError(ErrSignatureVersionNotSupported).HTTPStatusCode
    	if rec.Code != unsupportedSignature {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 77K bytes
    - Viewed (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/OkHttpClient.kt

     *     .build();
     * Response response = eagerClient.newCall(request).execute();
     * ```
     *
     * ## Shutdown Isn't Necessary
     *
     * The threads and connections that are held will be released automatically if they remain idle. But
     * if you are writing a application that needs to aggressively release unused resources you may do
     * so.
     *
     * Shutdown the dispatcher's executor service with [shutdown()][ExecutorService.shutdown]. This will
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon May 05 16:01:00 UTC 2025
    - 51.7K bytes
    - Viewed (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt

          sink.writeByte(0)
          sink.flush()
        }.also { expected ->
          assertThat(expected.message).isEqualTo("stream finished")
        }
        assertFailsWith<IOException> {
          stream.source.read(Buffer(), 1)
        }.also { expected ->
          assertThat(expected.message).isEqualTo("stream was reset: CANCEL")
        }
    
        // Verify the peer received what was expected.
        val synStream = peer.takeFrame()
    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. okhttp/src/jvmTest/kotlin/okhttp3/EventListenerTest.kt

          client.newCall(
            Request
              .Builder()
              .url(server.url("/"))
              .build(),
          )
        assertFailsWith<IOException> {
          call.execute()
        }.also { expected ->
          assertThat(expected.message).isIn("timeout", "Read timed out")
        }
        assertThat(listener.recordedEventTypes()).containsExactly(
          "CallStart",
          "ProxySelectStart",
          "ProxySelectEnd",
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 60.4K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/Futures.java

        executor.execute(task);
        return task;
      }
    
      /**
       * Executes {@code runnable} on the specified {@code executor}, returning a {@code Future} that
       * will complete after execution.
       *
       * @throws RejectedExecutionException if the task cannot be scheduled for execution
       * @since 28.2
       */
      public static ListenableFuture<@Nullable Void> submit(Runnable runnable, Executor executor) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 64.3K bytes
    - Viewed (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt

        setUp(protocol)
        server.enqueue(MockResponse(body = "A"))
        server.enqueue(MockResponse(body = "A"))
        val executor = Executors.newCachedThreadPool(threadFactory("HttpOverHttp2Test"))
        val countDownLatch = CountDownLatch(2)
        executor.execute(AsyncRequest("/r1", countDownLatch))
        executor.execute(AsyncRequest("/r2", countDownLatch))
        countDownLatch.await()
        assertThat(server.takeRequest().exchangeIndex).isEqualTo(0)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 73.4K bytes
    - Viewed (0)
  7. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/http/HcHttpClient.java

        }
    
        /**
         * Executes the HTTP client request.
         *
         * @param httpRequest The HTTP request to execute
         * @return The HTTP response
         * @throws IOException If an I/O error occurs
         */
        protected HttpResponse executeHttpClient(final HttpUriRequest httpRequest) throws IOException {
            return httpClient.execute(httpRequest, new BasicHttpContext(httpClientContext));
        }
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 52.2K bytes
    - Viewed (0)
  8. tests/migrate_test.go

    	}
    
    	if tableType.Schema() != tblSchema {
    		t.Fatalf("expected tblSchema to be %s but got %s", tblSchema, tableType.Schema())
    	}
    
    	if tableType.Name() != tblName {
    		t.Fatalf("expected table name to be %s but got %s", tblName, tableType.Name())
    	}
    
    	if tableType.Type() != tblType {
    		t.Fatalf("expected table type to be %s but got %s", tblType, tableType.Type())
    	}
    
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Wed Aug 20 04:51:17 UTC 2025
    - 65.2K bytes
    - Viewed (0)
  9. cmd/api-errors.go

    	},
    	ErrParseExpectedDatePart: {
    		Code:           "ParseExpectedDatePart",
    		Description:    "Did not find the expected date part in the SQL expression.",
    		HTTPStatusCode: http.StatusBadRequest,
    	},
    	ErrParseExpectedKeyword: {
    		Code:           "ParseExpectedKeyword",
    		Description:    "Did not find the expected keyword in the SQL expression.",
    		HTTPStatusCode: http.StatusBadRequest,
    	},
    	ErrParseExpectedTokenType: {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 16 07:34:24 UTC 2025
    - 93K bytes
    - Viewed (1)
  10. src/main/java/org/codelibs/fess/helper/ViewHelper.java

             * @param consumer the consumer to execute
             */
            public void godHandEpilogue(final ActionRuntime runtime, final Consumer<ActionRuntime> consumer) {
                consumer.accept(runtime);
            }
    
            /**
             * Before hook for action processing.
             *
             * @param runtime the action runtime
             * @param func the function to execute
             * @return the action response
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 52.4K bytes
    - Viewed (0)
Back to top