Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 21 - 30 of 276 for awaiter (0.07 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. android/guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java

        }
        return new ListenableFutureAdapter<>(future, executor);
      }
    
      /**
       * An adapter to turn a {@link Future} into a {@link ListenableFuture}. This will wait on the
       * future to finish, and when it completes, run the listeners. This implementation will wait on
       * the source future indefinitely, so if the source future never completes, the adapter will never
       * complete either.
       *
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Jul 17 15:26:41 GMT 2025
    - 7.5K bytes
    - Click Count (0)
  2. samples/guide/src/main/java/okhttp3/recipes/kt/ParseResponseWithMoshi.kt

    import okhttp3.OkHttpClient
    import okhttp3.Request
    
    class ParseResponseWithMoshi {
      private val client = OkHttpClient()
      private val moshi = Moshi.Builder().build()
      private val gistJsonAdapter = moshi.adapter(Gist::class.java)
    
      fun run() {
        val request =
          Request
            .Builder()
            .url("https://api.github.com/gists/c2a7c39532239ff261be")
            .build()
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 1.6K bytes
    - Click Count (0)
  3. src/main/java/org/codelibs/core/log/LoggerAdapter.java

     * either express or implied. See the License for the specific language
     * governing permissions and limitations under the License.
     */
    package org.codelibs.core.log;
    
    /**
     * Adapter for using any logging framework.
     *
     * @author koichik
     */
    interface LoggerAdapter {
    
        boolean isFatalEnabled();
    
        void fatal(String message);
    
        void fatal(String message, Throwable t);
    
    Created: Sat Dec 20 08:55:33 GMT 2025
    - Last Modified: Thu Jun 19 09:12:22 GMT 2025
    - 1.3K bytes
    - Click Count (0)
  4. src/archive/tar/testdata/writer-big-long.tar.base64

    Ian Lance Taylor <******@****.***> 1765577893 -0800
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Mon Dec 15 16:34:13 GMT 2025
    - 2K bytes
    - Click Count (0)
  5. src/main/java/org/codelibs/core/collection/EnumerationIterator.java

    import static org.codelibs.core.misc.AssertionUtil.assertArgumentNotNull;
    
    import java.util.Enumeration;
    import java.util.Iterator;
    
    import org.codelibs.core.exception.ClUnsupportedOperationException;
    
    /**
     * Adapter to convert an {@link Enumeration} to an {@link Iterator}.
     *
     * @author shot
     * @param <T> the element type
     */
    public class EnumerationIterator<T> implements Iterator<T> {
    
    Created: Sat Dec 20 08:55:33 GMT 2025
    - Last Modified: Thu Jun 19 09:12:22 GMT 2025
    - 2.2K bytes
    - Click Count (0)
  6. okhttp-hpacktests/src/test/java/okhttp3/internal/http2/hpackjson/HpackJsonUtil.kt

              @FromJson fun byteStringFromJson(json: String) = json.decodeHex()
            },
          ).add(KotlinJsonAdapterFactory())
          .build()
      private val STORY_JSON_ADAPTER = MOSHI.adapter(Story::class.java)
    
      private val fileSystem = FileSystem.SYSTEM
    
      private fun readStory(source: BufferedSource): Story = STORY_JSON_ADAPTER.fromJson(source)!!
    
      private fun readStory(file: Path): Story {
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 3.3K bytes
    - Click Count (0)
  7. docs/ko/docs/advanced/async-tests.md

    ///
    
    그 다음에  `AsyncClient` 로 앱을 만들고 비동기 요청을 `await` 키워드로 보낼 수 있습니다:
    
    {* ../../docs_src/async_tests/test_main.py hl[9:12] *}
    
    위의 코드는:
    
    ```Python
    response = client.get('/')
    ```
    
    `TestClient` 에 요청을 보내던 것과 동일합니다.
    
    /// tip | 팁
    
    새로운 `AsyncClient`를 사용할 때 async/await를 사용하고 있다는 점에 주목하세요. 이 요청은 비동기적으로 처리됩니다.
    
    ///
    
    /// warning | 경고
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Tue Dec 10 11:03:16 GMT 2024
    - 4.7K bytes
    - Click Count (0)
  8. guava/src/com/google/common/io/CharStreams.java

      }
    
      /**
       * Returns a {@link Writer} that simply discards written chars.
       *
       * <p><b>Java 11+ users:</b> use {@link Writer#nullWriter()} instead. Note that the {@link
       * CharStreams} method returns a singleton writer whose {@code close} method has no effect, while
       * the {@link Writer#nullWriter()} method returns a new instance whose methods throw after the
       * instance is {@link Writer#close() closed}.
       *
       * @since 15.0
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 29 13:56:24 GMT 2025
    - 11.9K bytes
    - Click Count (0)
  9. android-test/src/test/kotlin/okhttp/android/test/AndroidSocketAdapterTest.kt

        assertTrue(adapter.matchesSocket(sslSocket))
    
        adapter.configureTlsExtensions(sslSocket, null, listOf(HTTP_2, HTTP_1_1))
        // not connected
        assertNull(adapter.getSelectedProtocol(sslSocket))
      }
    
      @Test
      fun testMatchesSupportedAndroidSocketFactory() {
        assumeTrue(adapter is StandardAndroidSocketAdapter)
    
        assertTrue(adapter.matchesSocketFactory(context.socketFactory))
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 3.6K bytes
    - Click Count (0)
  10. cmd/object-api-interface.go

    }
    
    // GetObject - TODO(aead): This function just acts as an adapter for GetObject tests and benchmarks
    // since the GetObject method of the ObjectLayer interface has been removed. Once, the
    // tests are adjusted to use GetObjectNInfo this function can be removed.
    func GetObject(ctx context.Context, api ObjectLayer, bucket, object string, startOffset int64, length int64, writer io.Writer, etag string, opts ObjectOptions) (err error) {
    	var header http.Header
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 17.5K bytes
    - Click Count (0)
Back to Top