Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 218 for ShutDown (0.09 sec)

  1. mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt

        server2.start()
        server2.start()
        server2.shutdown()
      }
    
      @Test
      fun shutdownTwice() {
        val server2 = MockWebServer()
        server2.start()
        server2.shutdown()
        try {
          server2.start()
          fail<Unit>()
        } catch (expected: IllegalStateException) {
          // Expected.
        }
        server2.shutdown()
      }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 23.5K bytes
    - Viewed (0)
  2. mockwebserver/src/main/kotlin/mockwebserver3/Dispatcher.kt

      }
    
      /**
       * Release any resources held by this dispatcher. Any requests that are currently being dispatched
       * should return immediately. Responses returned after shutdown will not be transmitted: their
       * socket connections have already been closed.
       */
      open fun shutdown() {}
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Jan 23 14:31:42 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/AbstractIdleService.java

    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.TimeoutException;
    
    /**
     * Base class for services that do not need a thread while "running" but may need one during startup
     * and shutdown. Subclasses can implement {@link #startUp} and {@link #shutDown} methods, each which
     * run in an executor which by default uses a separate thread for each method.
     *
     * @author Chris Nokleberg
     * @since 1.0
     */
    @GwtIncompatible
    @J2ktIncompatible
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Apr 17 13:59:28 UTC 2023
    - 5.3K bytes
    - Viewed (0)
  4. mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/QueueDispatcher.kt

        throw UnsupportedOperationException("unexpected call")
      }
    
      fun enqueueResponse(response: MockResponse) {
        delegate.enqueueResponse(response.wrap())
      }
    
      override fun shutdown() {
        delegate.shutdown()
      }
    
      fun setFailFast(failFast: Boolean) {
        delegate.setFailFast(failFast)
      }
    
      fun setFailFast(failFastResponse: MockResponse?) {
        delegate.setFailFast(failFastResponse?.wrap())
      }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Oct 18 12:55:43 UTC 2020
    - 1.3K bytes
    - Viewed (0)
  5. mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt

      @Test
      fun shutdownWithoutStart() {
        val server = MockWebServer()
        server.shutdown()
      }
    
      @Test
      fun closeViaClosable() {
        val server: Closeable = MockWebServer()
        server.close()
      }
    
      @Test
      fun shutdownWithoutEnqueue() {
        val server = MockWebServer()
        server.start()
        server.shutdown()
      }
    
      @Test
      fun portImplicitlyStarts() {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  6. samples/guide/src/main/java/okhttp3/recipes/WebSocketEcho.java

        Request request = new Request.Builder()
            .url("ws://echo.websocket.org")
            .build();
        client.newWebSocket(request, this);
    
        // Trigger shutdown of the dispatcher's executor so this process exits immediately.
        client.dispatcher().executorService().shutdown();
      }
    
      @Override public void onOpen(WebSocket webSocket, Response response) {
        webSocket.send("Hello...");
        webSocket.send("...World!");
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 04 11:40:21 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  7. mockwebserver/src/main/kotlin/mockwebserver3/QueueDispatcher.kt

      }
    
      open fun enqueueResponse(response: MockResponse) {
        responseQueue.add(response)
      }
    
      open fun clear() {
        responseQueue.clear()
      }
    
      override fun shutdown() {
        responseQueue.add(DEAD_LETTER)
      }
    
      open fun setFailFast(failFast: Boolean) {
        val failFastResponse =
          if (failFast) {
            MockResponse(code = HttpURLConnection.HTTP_NOT_FOUND)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Jan 23 14:31:42 UTC 2024
    - 3K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java

        assertFalse(testExecutor.isTerminated());
        mock.assertLastMethodCalled("isTerminated");
        assertFalse(testExecutor.isShutdown());
        mock.assertLastMethodCalled("isShutdown");
        testExecutor.shutdown();
        mock.assertLastMethodCalled("shutdown");
        List<Runnable> list = testExecutor.shutdownNow();
        mock.assertLastMethodCalled("shutdownNow");
        assertEquals(ImmutableList.of(), list);
      }
    
      public void testExecute() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  9. mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt

      @Synchronized
      @Throws(IOException::class)
      fun shutdown() {
        if (shutdown) return
        shutdown = true
    
        if (!started) return // Nothing to shut down.
        val serverSocket = this.serverSocket ?: return // If this is null, start() must have failed.
    
        // Cause acceptConnections() to break out.
        serverSocket.close()
    
        // Await shutdown.
        for (queue in taskRunner.activeQueues()) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Mar 31 17:16:15 UTC 2024
    - 37.4K bytes
    - Viewed (0)
  10. mockwebserver-junit4/src/main/kotlin/mockwebserver3/junit4/MockWebServerRule.kt

        try {
          server.start()
        } catch (e: IOException) {
          throw RuntimeException(e)
        }
      }
    
      override fun after() {
        try {
          server.shutdown()
        } catch (e: IOException) {
          logger.log(Level.WARNING, "MockWebServer shutdown failed", e)
        }
      }
    
      @ExperimentalOkHttpApi
      companion object {
        private val logger = Logger.getLogger(MockWebServerRule::class.java.name)
      }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Jan 23 14:31:42 UTC 2024
    - 1.8K bytes
    - Viewed (0)
Back to top