Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 218 for ShutDown (0.09 sec)

  1. tests/test_ws_router.py

            data = websocket.receive_text()
            assert data == "a_query_param"
    
    
    def test_wrong_uri():
        """
        Verify that a websocket connection to a non-existent endpoing returns in a shutdown
        """
        client = TestClient(app)
        with pytest.raises(WebSocketDisconnect) as e:
            with client.websocket_connect("/no-router/"):
                pass  # pragma: no cover
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Jun 11 19:08:14 UTC 2023
    - 7.5K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

            future.get();
          } catch (Throwable t) {
            // Ignore, we just wanted to block.
          }
          String error = errorMessage.get();
          assertNull(error, error);
        }
        executor.shutdown();
      }
    
      /**
       * He did the bash, he did the future bash The future bash, it was a concurrency smash He did the
       * bash, it caught on in a flash He did the bash, he did the future bash
       */
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 47.1K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/FessBoot.java

                }
            }).useTldDetect(jarName -> (jarName.contains("jstl") || jarName.contains("lasta-taglib"))).asDevelopment(isNoneEnv()).bootAwait();
        }
    
        public static void shutdown(final String[] args) {
            System.exit(0);
        }
    
        private static boolean isNoneEnv() {
            return System.getProperty("lasta.env") == null;
        }
    
        protected static int getPort() {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 8K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/WrappingScheduledExecutorServiceTest.java

          throw new UnsupportedOperationException();
        }
    
        @Override
        public boolean isTerminated() {
          throw new UnsupportedOperationException();
        }
    
        @Override
        public void shutdown() {
          throw new UnsupportedOperationException();
        }
    
        @Override
        public List<Runnable> shutdownNow() {
          throw new UnsupportedOperationException();
        }
    
        @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/exec/ThumbnailGenerator.java

                while (count != 0) {
                    count = ComponentUtil.getThumbnailManager().generate(executorService, options.cleanup);
                    totalCount += count;
                }
                executorService.shutdown();
                executorService.awaitTermination(60, TimeUnit.SECONDS);
            } catch (final InterruptedException e) {
                if (logger.isDebugEnabled()) {
                    logger.debug("Interrupted.", e);
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  6. src/main/assemblies/files/service.bat

    	)
    )
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sun Jan 15 06:32:15 UTC 2023
    - 6K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/CallKotlinTest.kt

        val proxySelector = RecordingProxySelector()
        proxySelector.proxies.add(Proxy(Proxy.Type.HTTP, TestUtil.UNREACHABLE_ADDRESS_IPV4))
        proxySelector.proxies.add(Proxy.NO_PROXY)
        server.shutdown()
    
        client =
          client.newBuilder()
            .proxySelector(proxySelector)
            .readTimeout(Duration.ofMillis(100))
            .connectTimeout(Duration.ofMillis(100))
            .build()
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  8. CHANGELOG.md

        `LoggingEventListener.androidLogging()` write HTTP calls or events to Logcat.
    
     *  New: `OkHttpClient.webSocketCloseTimeout` configures how long a web socket connection will wait
        for a graceful shutdown before it performs an abrupt shutdown.
    
     *  Fix: Honor `RequestBody.isOneShot()` in `MultipartBody`
    
     *  Fix in `okhttp-coroutines`: Don't leak response bodies in `executeAsync()`. We had a bug where
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 18 01:31:39 UTC 2024
    - 21.4K bytes
    - Viewed (0)
  9. okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt

                }
              }
              return result
            }
    
            override fun peek(): MockResponse = queueDispatcher.peek()
    
            override fun shutdown() {
              queueDispatcher.shutdown()
            }
          }
        client =
          client.newBuilder()
            .proxy(server.toProxyAddress())
            .build()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 11 22:09:35 UTC 2024
    - 75.3K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt

            reader.nextFrame(false, inFrame)
            inFrames.add(inFrame)
          }
        }
      }
    
      fun openSocket(): Socket = Socket("localhost", port)
    
      @Synchronized override fun close() {
        executor.shutdown()
        socket?.closeQuietly()
        serverSocket?.closeQuietly()
      }
    
      override fun toString(): String = "MockHttp2Peer[$port]"
    
      private class OutFrame(
        val sequence: Int,
        val start: Long,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 11 22:09:35 UTC 2024
    - 8.7K bytes
    - Viewed (0)
Back to top