Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 24 for executes (0.04 sec)

  1. cmd/test-utils_test.go

    	t                 *testing.T
    	objAPITest        objAPITestType
    	endpoints         []string
    	init              func()
    	makeBucketOptions MakeBucketOptions
    }
    
    // ExecObjectLayerAPITest - executes object layer API tests.
    // Creates single node and Erasure ObjectLayer instance, registers the specified API end points and runs test for both the layers.
    func ExecObjectLayerAPITest(args ExecObjectLayerAPITestArgs) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 77K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. src/bufio/bufio_test.go

    }
    
    // An onlyWriter only implements io.Writer, no matter what other methods the underlying implementation may have.
    type onlyWriter struct {
    	io.Writer
    }
    
    // A scriptedReader is an io.Reader that executes its steps sequentially.
    type scriptedReader []func(p []byte) (n int, err error)
    
    func (sr *scriptedReader) Read(p []byte) (n int, err error) {
    	if len(*sr) == 0 {
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Fri Feb 07 01:08:54 UTC 2025
    - 51.6K bytes
    - Viewed (0)
  5. 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)
  6. okhttp/src/jvmTest/kotlin/okhttp3/EventListenerTest.kt

              .Builder()
              .url(server.url("/"))
              .build(),
          ).execute()
          .close()
        listener.removeUpToEvent<CallEnd>()
        val call =
          client.newCall(
            Request
              .Builder()
              .url(server.url("/"))
              .build(),
          )
        val response = call.execute()
        response.close()
        assertThat(listener.recordedEventTypes()).containsExactly(
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 60.4K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. docs/bucket/notifications/README.md

        print(" [x] %r" % body)
    
    channel.basic_consume(callback,
                          queue=queue_name,
                          no_ack=False)
    
    channel.start_consuming()
    ```
    
    Execute this example python program to watch for RabbitMQ events on the console.
    
    ```py
    python rabbit.py
    ```
    
    Open another terminal and upload a JPEG image into `images` bucket.
    
    ```
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 84.2K bytes
    - Viewed (0)
  10. tests/migrate_test.go

    			sql, _ := fc()
    			if strings.HasPrefix(sql, "ALTER TABLE \"migrate_ints\" ALTER COLUMN \"int8\" TYPE smallint") {
    				t.Fatalf("shouldn't execute ALTER COLUMN TYPE if such type is already existed in DB schema: sql: %s",
    					sql)
    			}
    		},
    	}
    
    	DB.Migrator().DropTable(&MigrateInt{})
    
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Wed Aug 20 04:51:17 UTC 2025
    - 65.2K bytes
    - Viewed (0)
Back to top