- Sort Score
- Result 10 results
- Languages All
Results 431 - 440 of 1,015 for executes (0.08 sec)
-
docs/pt/docs/tutorial/request_files.md
* `seek(offset)`: Navega para o byte na posição `offset` (`int`) do arquivo. * E.g., `await myfile.seek(0)` navegaria para o ínicio do arquivo. * Isso é especialmente útil se você executar `await myfile.read()` uma vez e depois precisar ler os conteúdos do arquivo de novo. * `close()`: Fecha o arquivo. Como todos esses métodos são assíncronos (`async`) você precisa esperar ("await") por eles.
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 06 20:36:54 UTC 2024 - 10.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http/ExternalHttp2Example.kt
.build() val call = client.newCall( Request.Builder() .url("https://www.google.ca/") .build(), ) val response = call.execute() try { println(response.code) println("PROTOCOL ${response.protocol}") var line: String? while (response.body.source().readUtf8Line().also { line = it } != null) { println(line)
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1.4K bytes - Viewed (0) -
regression-test/src/androidTest/java/okhttp/regression/compare/OkHttpClientTest.java
OkHttpClient client = new OkHttpClient(); Request request = new Request.Builder() .url("https://google.com/robots.txt") .build(); try (Response response = client.newCall(request).execute()) { assertEquals(200, response.code()); assertEquals(Protocol.HTTP_2, response.protocol()); } }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Nov 14 17:38:22 UTC 2020 - 1.4K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
assertFalse(future.isCancelled()); ExecutorService executor = Executors.newSingleThreadExecutor(); try { Future<Boolean> getResult = executor.submit(() -> future.get()); // Release the future value. latch.countDown(); assertTrue(getResult.get(10, SECONDS)); } finally { executor.shutdownNow(); } assertTrue(future.isDone());
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Sep 06 18:30:30 UTC 2023 - 6K bytes - Viewed (0) -
istioctl/cmd/istioctl/main.go
fmt.Fprintf(os.Stderr, "Could not initialize: %v\n", err) exitCode := cmd.GetExitCode(err) os.Exit(exitCode) } rootCmd := cmd.GetRootCmd(os.Args[1:]) log.EnableKlogWithCobra() if err := rootCmd.Execute(); err != nil { exitCode := cmd.GetExitCode(err) os.Exit(exitCode) }
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 1.1K bytes - Viewed (0) -
build-logic/binary-compatibility/src/main/groovy/gradlebuild/binarycompatibility/rules/AcceptedRegressionsRulePostProcess.java
import java.util.HashSet; import java.util.Set; public class AcceptedRegressionsRulePostProcess implements PostProcessViolationsRule { @Override @SuppressWarnings("unchecked") public void execute(ViolationCheckContextWithViolations context) { Set<ApiChange> acceptedApiChanges = (Set<ApiChange>) context.getUserData().get("acceptedApiChanges");
Registered: Wed Nov 06 11:36:14 UTC 2024 - Last Modified: Wed Jun 09 08:16:49 UTC 2021 - 1.7K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ForwardingListenableFuture.java
* the License. */ package com.google.common.util.concurrent; import com.google.common.annotations.GwtCompatible; import com.google.common.base.Preconditions; import java.util.concurrent.Executor; import org.checkerframework.checker.nullness.qual.Nullable; /** * A {@link ListenableFuture} which forwards all its method calls to another future. Subclasses
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Mar 04 12:23:41 UTC 2022 - 2.4K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Uninterruptibles.java
return awaitTerminationUninterruptibly(executor, toNanosSaturated(timeout), NANOSECONDS); } /** * Invokes {@code executor.}{@link ExecutorService#awaitTermination(long, TimeUnit) * awaitTermination(long, TimeUnit)} uninterruptibly. * * @since 30.0 */ @J2ktIncompatible @GwtIncompatible // concurrency @SuppressWarnings("GoodTime")
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:51:36 UTC 2024 - 19.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache2/RelayTest.kt
class RelayTest { @TempDir var tempDir: File? = null private val executor = Executors.newCachedThreadPool(threadFactory("RelayTest")) private val metadata: ByteString = "great metadata!".encodeUtf8() private lateinit var file: File @BeforeEach fun setUp() { file = File(tempDir, "test") } @AfterEach fun tearDown() { executor.shutdown() } @Test fun singleSource() {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 8.1K bytes - Viewed (0) -
docs/pt/docs/advanced/events.md
``` Quando você cria um gerenciador de contexto ou um gerenciador de contexto assíncrono como mencionado acima, o que ele faz é que, antes de entrar no bloco `with`, ele irá executar o código anterior ao `yield`, e depois de sair do bloco `with`, ele irá executar o código depois do `yield`. No nosso exemplo de código acima, nós não usamos ele diretamente, mas nós passamos para o FastAPI para ele usá-lo.
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 06 20:36:54 UTC 2024 - 8.6K bytes - Viewed (0)