Search Options

Results per page
Sort
Preferred Languages
Advance

Results 251 - 260 of 369 for Kqueue (0.03 sec)

  1. docs/en/docs/tutorial/background-tasks.md

    They tend to require more complex configurations, a message/job queue manager, like RabbitMQ or Redis, but they allow you to run background tasks in multiple processes, and especially, in multiple servers.
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 09:15:41 UTC 2025
    - 4.8K bytes
    - Viewed (0)
  2. samples/compare/src/test/kotlin/okhttp3/compare/JavaHttpClientTest.kt

      @Test fun get() {
        // Not available
        platform.expectFailureOnJdkVersion(8)
    
        val httpClient =
          HttpClient
            .newBuilder()
            .followRedirects(NORMAL)
            .build()
    
        server.enqueue(
          MockResponse
            .Builder()
            .body("hello, Java HTTP Client")
            .build(),
        )
    
        val request =
          HttpRequest
            .newBuilder(server.url("/").toUri())
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Jun 18 12:28:21 UTC 2025
    - 2.8K bytes
    - Viewed (0)
  3. guava-testlib/src/com/google/common/testing/ArbitraryInstances.java

    import java.util.NavigableMap;
    import java.util.NavigableSet;
    import java.util.Optional;
    import java.util.OptionalDouble;
    import java.util.OptionalInt;
    import java.util.OptionalLong;
    import java.util.Queue;
    import java.util.Random;
    import java.util.Set;
    import java.util.SortedMap;
    import java.util.SortedSet;
    import java.util.UUID;
    import java.util.concurrent.BlockingDeque;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 21.4K bytes
    - Viewed (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/OpenJSSETest.kt

      @StartStop
      private val server = MockWebServer()
    
      @BeforeEach
      fun setUp() {
        platform.assumeOpenJSSE()
      }
    
      @Test
      fun testTlsv13Works() {
        enableTls()
    
        server.enqueue(MockResponse(body = "abc"))
    
        val request = Request(server.url("/"))
    
        val response = client.newCall(request).execute()
    
        response.use {
          assertEquals(200, response.code)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Jun 18 12:28:21 UTC 2025
    - 3.7K bytes
    - Viewed (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Interceptor.kt

     *
     * Other exception types cancel the current call:
     *
     *  * For synchronous calls made with [Call.execute], the exception is propagated to the caller.
     *
     *  * For asynchronous calls made with [Call.enqueue], an [IOException] is propagated to the caller
     *    indicating that the call was canceled. The interceptor's exception is delivered to the current
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  6. src/main/webapp/css/admin/respond.min.js

    a.ActiveXObject("Microsoft.XMLHTTP")}return function(){return b}}(),f=function(a,b){var c=e();c&&(c.open("GET",a,!0),c.onreadystatechange=function(){4!==c.readyState||200!==c.status&&304!==c.status||b(c.responseText)},4!==c.readyState&&c.send(null))};if(c.ajax=f,c.queue=d,c.regex={media:/@media[^\{]+\{([^\{\}]*\{[^\}\{]*\})+/gi,keyframes:/@(?:\-(?:o|moz|webkit)\-)?keyframes[^\{]+\{(?:[^\{\}]*\{[^\}\{]*\})+[^\}]*\}/gi,urls:/(url\()['"]?([^\/\)'"][^:\)'"]+)['"]?(\))/g,findStyles:/@media *([^\{]+)\{([\S\s]+?)$/,only...
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Oct 08 12:14:13 UTC 2015
    - 4.3K bytes
    - Viewed (0)
  7. CODE_OF_CONDUCT.md

    
    ## Conflict Resolution
    
    Conflicts in an open source project can take many forms, from someone having a bad day and using harsh and hurtful language in the issue queue, to more serious instances such as sexist/racist statements or threats of violence, and everything in between.
    
    If the behavior is threatening or harassing, or for other reasons requires immediate escalation, please see below.
    
    Registered: Tue Sep 09 12:39:10 UTC 2025
    - Last Modified: Fri Feb 05 18:43:16 UTC 2021
    - 5.2K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/ExecutionList.java

        // contract.
        // This is somewhat annoying, but turns out to be very fast in practice. Alternatively, we could
        // drop the contract on the method that enforces this queue like behavior since depending on it
        // is likely to be a bug anyway.
    
        // N.B. All writes to the list and the next pointers must have happened before the above
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  9. guava/src/com/google/common/util/concurrent/ExecutionList.java

        // contract.
        // This is somewhat annoying, but turns out to be very fast in practice. Alternatively, we could
        // drop the contract on the method that enforces this queue like behavior since depending on it
        // is likely to be a bug anyway.
    
        // N.B. All writes to the list and the next pointers must have happened before the above
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/cache/LocalLoadingCacheTest.java

        Set<Object> actualValues = ImmutableSet.copyOf(map.values());
        assertEquals(expectedValues, actualValues);
      }
    
      /** Lookups on the map view shouldn't impact the recency queue. */
      public void testAsMapRecency() {
        CacheBuilder<Object, Object> builder =
            createCacheBuilder().concurrencyLevel(1).maximumSize(SMALL_MAX_SIZE);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 12.4K bytes
    - Viewed (0)
Back to top