Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 182 for unqueued (0.07 sec)

  1. guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

        /**
         * Used to update and read the latestTaskQueue field. Set to null once the runnable has been run
         * or queued.
         */
        @CheckForNull ExecutionSequencer sequencer;
    
        /**
         * Executor the task was set to run on. Set to null when the task has been queued, run, or
         * cancelled.
         */
        @CheckForNull Executor delegate;
    
        /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/DispatcherTest.kt

        dispatcher.maxRequests = 2
        client.newCall(newRequest("http://a/1")).enqueue(callback)
        client.newCall(newRequest("http://b/1")).enqueue(callback)
        client.newCall(newRequest("http://c/1")).enqueue(callback)
        client.newCall(newRequest("http://a/2")).enqueue(callback)
        client.newCall(newRequest("http://b/2")).enqueue(callback)
        dispatcher.maxRequests = 4
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Fri Apr 05 03:30:42 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/ServerTruncatesRequestTest.kt

        // makeSimpleCall() because it uses the MockResponse enqueued above.
        val callB = client.newCall(Request(server.url("/")))
        callB.execute().use { response ->
          assertThat(response.body.string()).isEqualTo("abc")
        }
      }
    
      private fun makeSimpleCall() {
        server.enqueue(MockResponse(body = "healthy"))
        val callB = client.newCall(Request(server.url("/")))
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  4. mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt

      /**
       * Test that MockWebServer blocks for a call to enqueue() if a request is made before a mock
       * response is ready.
       */
      @Test
      fun dispatchBlocksWaitingForEnqueue() {
        Thread {
          try {
            Thread.sleep(1000)
          } catch (ignored: InterruptedException) {
          }
          server.enqueue(
            MockResponse.Builder()
              .body("enqueued in the background")
              .build(),
          )
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 23.5K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

        /**
         * Used to update and read the latestTaskQueue field. Set to null once the runnable has been run
         * or queued.
         */
        @CheckForNull ExecutionSequencer sequencer;
    
        /**
         * Executor the task was set to run on. Set to null when the task has been queued, run, or
         * cancelled.
         */
        @CheckForNull Executor delegate;
    
        /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  6. mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt

      }
    
      /**
       * Test that MockWebServer blocks for a call to enqueue() if a request is made before a mock
       * response is ready.
       */
      @Test
      fun dispatchBlocksWaitingForEnqueue() {
        Thread {
          try {
            Thread.sleep(1000)
          } catch (ignored: InterruptedException) {
          }
          server.enqueue(MockResponse().setBody("enqueued in the background"))
        }.start()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  7. mockwebserver/README.md

      // instance for every unit test.
      MockWebServer server = new MockWebServer();
    
      // Schedule some responses.
      server.enqueue(new MockResponse().setBody("hello, world!"));
      server.enqueue(new MockResponse().setBody("sup, bra?"));
      server.enqueue(new MockResponse().setBody("yo dog"));
    
      // Start the server.
      server.start();
    
      // Ask the server for its URL. You'll need this to make HTTP requests.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Dec 17 15:34:10 UTC 2023
    - 5K bytes
    - Viewed (0)
  8. src/main/webapp/js/admin/jquery-3.7.1.min.map

    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Oct 26 01:07:52 UTC 2024
    - 131.6K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java

      enum WorkerRunningState {
        /** Runnable is not running and not queued for execution */
        IDLE,
        /** Runnable is not running, but is being queued for execution */
        QUEUING,
        /** runnable has been submitted but has not yet begun execution */
        QUEUED,
        RUNNING,
      }
    
      /** Underlying executor that all submitted Runnable objects are run on. */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  10. guava/src/com/google/common/util/concurrent/SequentialExecutor.java

      enum WorkerRunningState {
        /** Runnable is not running and not queued for execution */
        IDLE,
        /** Runnable is not running, but is being queued for execution */
        QUEUING,
        /** runnable has been submitted but has not yet begun execution */
        QUEUED,
        RUNNING,
      }
    
      /** Underlying executor that all submitted Runnable objects are run on. */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 10.6K bytes
    - Viewed (0)
Back to top