Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 163 for teardown (0.06 sec)

  1. guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

     *       defined this way, but enough to live with.
     *   <li>If you override {@link #setUp} or {@link #tearDown}, make sure to invoke {@code
     *       super.setUp} and {@code super.tearDown} within them. These methods are used to clear and
     *       check for thread assertion failures.
     *   <li>All delays and timeouts must use one of the constants {@code SHORT_DELAY_MS}, {@code
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 37.9K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/internal/ws/WebSocketReaderTest.kt

        WebSocketReader(
          isClient = true,
          source = data,
          frameCallback = callback.asFrameCallback(),
          perMessageDeflate = true,
          noContextTakeover = false,
        )
    
      @AfterEach fun tearDown() {
        callback.assertExhausted()
      }
    
      @Test fun controlFramesMustBeFinal() {
        data.write("0a00".decodeHex()) // Empty pong.
        assertFailsWith<ProtocolException> {
          clientReader.processNextFrame()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 14.4K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/collect/QueuesTest.java

       * be a SynchronousQueue.
       */
      private ExecutorService threadPool;
    
      @Override
      public void setUp() {
        threadPool = newCachedThreadPool();
      }
    
      @Override
      public void tearDown() throws InterruptedException {
        threadPool.shutdown();
        assertTrue("Some worker didn't finish in time", threadPool.awaitTermination(10, SECONDS));
      }
    
      private static <T> int drain(
          BlockingQueue<T> q,
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

        if (hung) {
          assertEquals(expectedOutcome, Outcome.HANG);
        } else {
          assertNull(task.get(UNEXPECTED_HANG_DELAY_MILLIS, TimeUnit.MILLISECONDS));
        }
      }
    
      @Override
      protected void tearDown() throws Exception {
        // We don't want to leave stray threads running after each test. At this point, every thread
        // launched by this test is either:
        //
        // (a) Blocked attempting to enter the monitor.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 23 14:18:12 UTC 2024
    - 27.1K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/OkHttpClientTest.kt

      @RegisterExtension
      val clientTestRule = OkHttpClientTestRule()
    
      private var server: MockWebServer? = null
    
      @BeforeEach fun setUp(server: MockWebServer?) {
        this.server = server
      }
    
      @AfterEach fun tearDown() {
        ProxySelector.setDefault(DEFAULT_PROXY_SELECTOR)
        CookieManager.setDefault(DEFAULT_COOKIE_HANDLER)
        ResponseCache.setDefault(DEFAULT_RESPONSE_CACHE)
      }
    
      @Test fun durationDefaults() {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Mar 31 17:16:15 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  6. compat/maven-embedder/src/test/java/org/apache/maven/cli/event/ExecutionEventLoggerTest.java

        @BeforeAll
        static void setUp() {
            MessageUtils.setColorEnabled(false);
        }
    
        @AfterAll
        static void tearDown() {
            MessageUtils.setColorEnabled(true);
        }
    
        @BeforeEach
        void beforeEach() {
            logger = mock(Logger.class);
            when(logger.isInfoEnabled()).thenReturn(true);
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 12.2K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/internal/connection/RouteSelectorTest.kt

        call =
          clientTestRule.newClient().newCall(
            Request.Builder()
              .url("https://$uriHost:$uriPort/")
              .build(),
          ) as RealCall
      }
    
      @AfterEach fun tearDown() {
        factory.close()
      }
    
      @Test fun singleRoute() {
        val address = factory.newAddress()
        val routeSelector = newRouteSelector(address)
        assertThat(routeSelector.hasNext()).isTrue()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Mar 06 17:33:38 UTC 2024
    - 20.8K bytes
    - Viewed (0)
  8. okhttp/src/test/java/okhttp3/DuplexTest.kt

      @BeforeEach
      fun setUp(server: MockWebServer) {
        this.server = server
        platform.assumeNotOpenJSSE()
        platform.assumeHttp2Support()
      }
    
      @AfterEach
      fun tearDown() {
        executorService.shutdown()
      }
    
      @Test
      @Throws(IOException::class)
      fun http1DoesntSupportDuplex() {
        val call =
          client.newCall(
            Request.Builder()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 23.9K bytes
    - Viewed (0)
  9. okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt

      private val addressB = factory.newAddress("b")
      private val routeB1 = factory.newRoute(addressB)
      private val addressC = factory.newAddress("c")
      private val routeC1 = factory.newRoute(addressC)
    
      @AfterEach fun tearDown() {
        factory.close()
        peer.close()
      }
    
      @Test fun connectionsEvictedWhenIdleLongEnough() {
        val pool = factory.newConnectionPool()
        val c1 = factory.newConnection(pool, routeA1, 50L)
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jun 22 16:06:35 UTC 2024
    - 12.8K bytes
    - Viewed (0)
  10. src/test/java/org/codelibs/fess/it/search/SearchApiTests.java

            startJob(NAME_PREFIX);
    
            waitJob(NAME_PREFIX);
            refresh();
        }
    
        @BeforeEach
        protected void init() {
            refresh();
        }
    
        @AfterEach
        protected void tearDown() {
        }
    
        @AfterAll
        protected static void tearDownAll() {
            deleteDocuments("label:" + CRAWL_LABEL);
            deleteLabel(labelId);
            deleteLabel(crawlLabelId);
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 18.6K bytes
    - Viewed (0)
Back to top