Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 202 for Milliseconds (0.07 sec)

  1. okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt

    import assertk.assertions.startsWith
    import assertk.fail
    import java.io.IOException
    import java.net.ServerSocket
    import java.net.Socket
    import java.util.concurrent.CountDownLatch
    import java.util.concurrent.TimeUnit.MILLISECONDS
    import javax.net.ServerSocketFactory
    import javax.net.SocketFactory
    import kotlin.test.assertFailsWith
    import mockwebserver3.MockResponse
    import mockwebserver3.MockWebServer
    import okhttp3.Call
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java

     * the License.
     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
    import static java.util.concurrent.TimeUnit.MILLISECONDS;
    
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.annotations.J2ktIncompatible;
    import com.google.common.base.Preconditions;
    import com.google.errorprone.annotations.concurrent.LazyInit;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  3. src/main/resources/fess_env_suggest.properties

    framework.debug = false
    
    # one day: 86400000, three days: 259200000, five days: 432000000, one week: 604800000, one year: 31556926000
    # special script :: absolute mode: $(2014/07/10), relative mode: addDay(3).addMonth(4)
    # The milliseconds for (relative or absolute) adjust time (set only when test) @LongType *dynamic in development
    time.adjust.time.millis = 0
    
    # ----------------------------------------------------------
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Mon Jan 29 07:34:32 UTC 2018
    - 2.2K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2ExchangeCodec.kt

          stream!!.closeLater(ErrorCode.CANCEL)
          throw IOException("Canceled")
        }
        stream!!.readTimeout().timeout(chain.readTimeoutMillis.toLong(), TimeUnit.MILLISECONDS)
        stream!!.writeTimeout().timeout(chain.writeTimeoutMillis.toLong(), TimeUnit.MILLISECONDS)
      }
    
      override fun flushRequest() {
        http2Connection.flush()
      }
    
      override fun finishRequest() {
        stream!!.getSink().close()
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

                : UNEXPECTED_HANG_DELAY_MILLIS;
        boolean hung =
            !awaitUninterruptibly(callCompletedLatch, hangDelayMillis, TimeUnit.MILLISECONDS);
        if (hung) {
          assertEquals(expectedOutcome, Outcome.HANG);
        } else {
          assertNull(task.get(UNEXPECTED_HANG_DELAY_MILLIS, TimeUnit.MILLISECONDS));
        }
      }
    
      @Override
      protected void tearDown() throws Exception {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 27.1K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java

     * limitations under the License.
     */
    
    package com.google.common.util.concurrent;
    
    import static com.google.common.truth.Truth.assertThat;
    import static java.util.concurrent.TimeUnit.MILLISECONDS;
    import static org.junit.Assert.assertThrows;
    
    import com.google.common.testing.TearDown;
    import com.google.common.testing.TearDownStack;
    import com.google.common.util.concurrent.testing.TestingExecutors;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/cache/PopulatedCachesTest.java

            .withExpireAfterWrites(
                ImmutableSet.of(
                    // DurationSpec.of(500, MILLISECONDS),
                    DurationSpec.of(1, SECONDS), DurationSpec.of(1, DAYS)))
            .withExpireAfterAccesses(
                ImmutableSet.of(
                    // DurationSpec.of(500, MILLISECONDS),
                    DurationSpec.of(1, SECONDS), DurationSpec.of(1, DAYS)))
            .withRefreshes(
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 02 18:21:29 UTC 2024
    - 15K bytes
    - Viewed (0)
  8. samples/guide/src/main/java/okhttp3/recipes/WebSocketEcho.java

    import okio.ByteString;
    
    public final class WebSocketEcho extends WebSocketListener {
      private void run() {
        OkHttpClient client = new OkHttpClient.Builder()
            .readTimeout(0,  TimeUnit.MILLISECONDS)
            .build();
    
        Request request = new Request.Builder()
            .url("ws://echo.websocket.org")
            .build();
        client.newWebSocket(request, this);
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 04 11:40:21 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  9. mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt

        assertThat(request.requestLine).isEqualTo("GET / HTTP/1.1")
        assertThat(request.getHeader("Accept-Language")).isEqualTo("en-US")
    
        // Server has no more requests.
        assertThat(server.takeRequest(100, TimeUnit.MILLISECONDS)).isNull()
      }
    
      @Test
      fun redirect() {
        server.enqueue(
          MockResponse()
            .setResponseCode(HttpURLConnection.HTTP_MOVED_TEMP)
            .addHeader("Location: " + server.url("/new-path"))
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  10. mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt

        assertThat(request.requestLine).isEqualTo("GET / HTTP/1.1")
        assertThat(request.headers["Accept-Language"]).isEqualTo("en-US")
    
        // Server has no more requests.
        assertThat(server.takeRequest(100, TimeUnit.MILLISECONDS)).isNull()
      }
    
      @Test
      fun redirect() {
        server.enqueue(
          MockResponse.Builder()
            .code(HttpURLConnection.HTTP_MOVED_TEMP)
            .addHeader("Location: " + server.url("/new-path"))
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 23.5K bytes
    - Viewed (0)
Back to top