Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 59 for asynchronously (0.19 sec)

  1. docs/en/docs/advanced/custom-response.md

    !!! tip
        Notice that here as we are using standard `open()` that doesn't support `async` and `await`, we declare the path operation with normal `def`.
    
    ### `FileResponse`
    
    Asynchronously streams a file as the response.
    
    Takes a different set of arguments to instantiate than the other response types:
    
    * `path` - The filepath to the file to stream.
    Plain Text
    - Registered: Sun May 05 07:19:11 GMT 2024
    - Last Modified: Thu Apr 18 19:53:19 GMT 2024
    - 11.7K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/InterceptorTest.kt

            .build()
        val responseB = client.newCall(requestB).execute()
        assertThat(responseB.body.string()).isEqualTo("b")
      }
    
      /** Make sure interceptors can interact with the OkHttp client asynchronously.  */
      @Test
      fun interceptorMakesAnUnrelatedAsyncRequest() {
        server.enqueue(MockResponse.Builder().body("a").build()) // Fetched by interceptor.
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sun Jan 14 10:20:09 GMT 2024
    - 27.8K bytes
    - Viewed (0)
  3. docs/en/docs/async.md

    * **Asynchronous Code**
    * **`async` and `await`**
    * **Coroutines**
    
    ## Asynchronous Code
    
    Asynchronous code just means that the language 💬 has a way to tell the computer / program 🤖 that at some point in the code, it 🤖 will have to wait for *something else* to finish somewhere else. Let's say that *something else* is called "slow-file" 📝.
    
    So, during that time, the computer can go and do some other work, while "slow-file" 📝 finishes.
    Plain Text
    - Registered: Sun May 05 07:19:11 GMT 2024
    - Last Modified: Thu Apr 18 19:53:19 GMT 2024
    - 23K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt

          receivedCloseCode = code
          receivedCloseReason = reason
        }
    
        listener.onClosing(this, code, reason)
      }
    
      // Writer methods to enqueue frames. They'll be sent asynchronously by the writer thread.
    
      override fun send(text: String): Boolean {
        return send(text.encodeUtf8(), OPCODE_TEXT)
      }
    
      override fun send(bytes: ByteString): Boolean {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 01 14:21:25 GMT 2024
    - 22.1K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

      internal var nextStreamId = if (builder.client) 3 else 2
    
      private var isShutdown = false
    
      /** For scheduling everything asynchronous. */
      private val taskRunner = builder.taskRunner
    
      /** Asynchronously writes frames to the outgoing socket. */
      private val writerQueue = taskRunner.newQueue()
    
      /** Ensures push promise callbacks events are sent in order per stream. */
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 32.6K bytes
    - Viewed (0)
  6. docs/en/docs/tutorial/sql-databases.md

    def read_user(user_id: int, db: Session = Depends(get_db)):
        db_user = crud.get_user(db, user_id=user_id)
        ...
    ```
    
    !!! info
        If you need to connect to your relational database asynchronously, see [Async SQL (Relational) Databases](../how-to/async-sql-encode-databases.md){.internal-link target=_blank}.
    
    !!! note "Very Technical Details"
    Plain Text
    - Registered: Sun May 05 07:19:11 GMT 2024
    - Last Modified: Thu Apr 18 19:53:19 GMT 2024
    - 29.6K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/Futures.java

        if (delegate.isDone()) {
          return delegate;
        }
        return TimeoutFuture.create(delegate, time, unit, scheduledExecutor);
      }
    
      /**
       * Returns a new {@code Future} whose result is asynchronously derived from the result of the
       * given {@code Future}. If the given {@code Future} fails, the returned {@code Future} fails with
       * the same exception (and the function is not invoked).
       *
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 01 16:15:01 GMT 2024
    - 59.6K bytes
    - Viewed (0)
  8. cmd/xl-storage-format-v2.go

    // deleted/overwritten version. This version is visible _only_to the scanner routine, for subsequent deletion.
    // This kind of tracking is necessary since a version's tiered content is deleted asynchronously.
    
    // Backend directory tree structure:
    // disk1/
    // └── bucket
    //     └── object
    //         ├── a192c1d5-9bd5-41fd-9a90-ab10e165398d
    //         │   └── part.1
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 05:07:37 GMT 2024
    - 63.6K bytes
    - Viewed (1)
  9. android/guava/src/com/google/common/cache/CacheBuilder.java

       * @throws IllegalArgumentException if {@code duration} is negative
       * @throws IllegalStateException if {@link #refreshAfterWrite} was already set
       * @since 11.0
       */
      @GwtIncompatible // To be supported (synchronously).
      @SuppressWarnings("GoodTime") // should accept a java.time.Duration
      @CanIgnoreReturnValue
      public CacheBuilder<K, V> refreshAfterWrite(long duration, TimeUnit unit) {
        checkNotNull(unit);
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Feb 15 16:12:13 GMT 2024
    - 44.8K bytes
    - Viewed (0)
  10. guava/src/com/google/common/cache/CacheBuilder.java

       * @throws IllegalArgumentException if {@code duration} is negative
       * @throws IllegalStateException if {@link #refreshAfterWrite} was already set
       * @since 11.0
       */
      @GwtIncompatible // To be supported (synchronously).
      @SuppressWarnings("GoodTime") // should accept a java.time.Duration
      @CanIgnoreReturnValue
      public CacheBuilder<K, V> refreshAfterWrite(long duration, TimeUnit unit) {
        checkNotNull(unit);
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Thu Feb 15 16:12:13 GMT 2024
    - 51.3K bytes
    - Viewed (0)
Back to top