Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 218 for ShutDown (0.07 sec)

  1. mockwebserver-deprecated/api/mockwebserver.api

    	public fun <init> ()V
    	public abstract fun dispatch (Lokhttp3/mockwebserver/RecordedRequest;)Lokhttp3/mockwebserver/MockResponse;
    	public fun peek ()Lokhttp3/mockwebserver/MockResponse;
    	public fun shutdown ()V
    }
    
    public final class okhttp3/mockwebserver/MockResponse : java/lang/Cloneable {
    	public static final field Companion Lokhttp3/mockwebserver/MockResponse$Companion;
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jul 22 12:28:51 UTC 2023
    - 10.2K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/DispatcherTest.kt

        proceed.countDown()
        t1.join()
        assertThat(idle.get()).isTrue()
      }
    
      @Test
      fun executionRejectedImmediately() {
        val request = newRequest("http://a/1")
        executor.shutdown()
        client.newCall(request).enqueue(callback)
        callback.await(request.url).assertFailure(InterruptedIOException::class.java)
        assertThat(listener.recordedEventTypes())
    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/RouteFailureTest.kt

          .assertSuccessful()
          .assertCode(200)
    
        println("server1.requestCount ${server1.requestCount}")
        assertThat(server1.requestCount).isEqualTo(1)
    
        // Shutdown the proxy server
        if (cleanShutdown) {
          server1.shutdown()
        }
    
        // Now redirect with DNS to proxyServer2
        // Then redirect socket connection to server2
        dns["myproxy"] = listOf(proxyServer2)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue May 14 17:48:07 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  4. docs/em/docs/advanced/testing-events.md

    # ๐Ÿ”ฌ ๐ŸŽ‰: ๐Ÿ•ด - ๐Ÿคซ
    
    ๐Ÿ•โ” ๐Ÿ‘† ๐Ÿ’ช ๐Ÿ‘† ๐ŸŽ‰ ๐Ÿ•โ€๐Ÿฆบ (`startup` &amp; `shutdown`) ๐Ÿƒ ๐Ÿ‘† ๐Ÿ’ฏ, ๐Ÿ‘† ๐Ÿ’ช โš™๏ธ `TestClient` โฎ๏ธ `with` ๐Ÿ“„:
    
    ```Python hl_lines="9-12  20-24"
    {!../../docs_src/app_testing/tutorial003.py!}
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 245 bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt

        override fun execute(
          taskRunner: TaskRunner,
          runnable: Runnable,
        ) {
          executor.execute(runnable)
        }
    
        fun shutdown() {
          executor.shutdown()
        }
      }
    
      companion object {
        val logger: Logger = Logger.getLogger(TaskRunner::class.java.name)
    
        @JvmField
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 29 00:33:04 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  6. src/packaging/common/systemd/fess.service

    # Set to "infinity" if you use the 'bootstrap.mlockall: true' option
    # in fess.yml and 'MAX_LOCKED_MEMORY=unlimited' in ${packaging.env.file}
    #LimitMEMLOCK=infinity
    
    # Shutdown delay in seconds, before process is tried to be killed with KILL (if configured)
    TimeoutStopSec=20
    
    [Install]
    WantedBy=multi-user.target
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sun Jan 15 06:32:15 UTC 2023
    - 1.1K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerTest.kt

        redQueue.shutdown()
    
        redQueue.execute("task", 100.ยตs) {
          // Do nothing.
        }
    
        taskFaker.assertNoMoreTasks()
    
        assertThat(testLogHandler.takeAll()).containsExactly(
          "FINE: Q10000 schedule canceled (queue is shutdown): task",
        )
      }
    
      @Test fun scheduleThrowsWhenShutdown() {
        redQueue.shutdown()
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 29 00:33:04 UTC 2024
    - 23K bytes
    - Viewed (0)
  8. android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

        assertTrue(future.isDone());
    
        assertTrue(successLatch.await(200, MILLISECONDS));
        assertTrue(listenerLatch.await(200, MILLISECONDS));
    
        latch.countDown();
    
        exec.shutdown();
        exec.awaitTermination(100, MILLISECONDS);
      }
    
      /**
       * Tests that all listeners complete, even if they were added before or after the future was
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 18:30:30 UTC 2023
    - 6K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/AbstractService.java

       */
      @ForOverride
      protected abstract void doStart();
    
      /**
       * This method should be used to initiate service shutdown. The invocation of this method should
       * cause a call to {@link #notifyStopped()}, either during this method's run, or after it has
       * returned. If shutdown fails, the invocation should cause a call to {@link
       * #notifyFailed(Throwable)} instead.
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 20.4K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

        ignoreIoExceptions {
          socket.close()
        }
    
        // Release the threads.
        writerQueue.shutdown()
        pushQueue.shutdown()
        settingsListenerQueue.shutdown()
      }
    
      private fun failConnection(e: IOException?) {
        close(ErrorCode.PROTOCOL_ERROR, ErrorCode.PROTOCOL_ERROR, e)
      }
    
      /**
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 32.6K bytes
    - Viewed (0)
Back to top