Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 473 for serving (0.14 sec)

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

        assertEquals(1, service.startUpCalled);
        assertEquals(Service.State.FAILED, service.state());
        assertThat(service.transitionStates).containsExactly(Service.State.STARTING);
      }
    
      public void testStop_withoutStart() {
        TestService service = new TestService();
        service.stopAsync().awaitTerminated();
        assertEquals(0, service.startUpCalled);
        assertEquals(0, service.shutDownCalled);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

      public ServiceManager startAsync() {
        for (Service service : services) {
          checkState(service.state() == NEW, "Not all services are NEW, cannot start %s", this);
        }
        for (Service service : services) {
          try {
            state.tryStartTiming(service);
            service.startAsync();
          } catch (IllegalStateException e) {
            // This can happen if the service has already been started or stopped (e.g. by another
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 33.5K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/ServiceManager.java

      public ServiceManager startAsync() {
        for (Service service : services) {
          checkState(service.state() == NEW, "Not all services are NEW, cannot start %s", this);
        }
        for (Service service : services) {
          try {
            state.tryStartTiming(service);
            service.startAsync();
          } catch (IllegalStateException e) {
            // This can happen if the service has already been started or stopped (e.g. by another
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt

         * @param host an IP address or hostname.
         * @param port the IP port associated with the service.
         * @param maxAge time in seconds that this alternative is considered fresh.
         */
        fun alternateService(
          streamId: Int,
          origin: String,
          protocol: ByteString,
          host: String,
          port: Int,
          maxAge: Long,
        )
      }
    
      companion object {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        ExecutorService service = mock(ExecutorService.class);
        application.addDelayedShutdownHook(service, 2, SECONDS);
        verify(service, Mockito.never()).shutdown();
        application.shutdown();
        InOrder shutdownFirst = Mockito.inOrder(service);
        shutdownFirst.verify(service).shutdown();
        shutdownFirst.verify(service).awaitTermination(2, SECONDS);
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/AbstractService.java

    import static com.google.common.util.concurrent.Service.State.FAILED;
    import static com.google.common.util.concurrent.Service.State.NEW;
    import static com.google.common.util.concurrent.Service.State.RUNNING;
    import static com.google.common.util.concurrent.Service.State.STARTING;
    import static com.google.common.util.concurrent.Service.State.STOPPING;
    import static com.google.common.util.concurrent.Service.State.TERMINATED;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 20.7K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/base/Predicate.java

     * Otherwise, at least reduce <i>explicit</i> dependencies on this type by using lambda expressions
     * or method references instead of classes, leaving your code easier to migrate in the future.
     *
     * <p>To use a reference of this type (say, named {@code guavaPredicate}) in a context where {@code
     * java.util.function.Predicate} is expected, use the method reference {@code
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 15 16:12:13 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  8. regression-test/src/androidTest/java/okhttp/regression/compare/ApacheHttpClientHttp2Test.kt

    /**
     * Simplified from
     * https://hc.apache.org/httpcomponents-client-5.0.x/httpclient5/examples/AsyncClientTlsAlpn.java
     *
     * Mainly intended to verify behaviour of popular clients across Android versions, similar
     * to observing Firefox or Chrome browser behaviour.
     */
    class ApacheHttpClientHttp2Test {
      @Test
      fun testHttp2() {
        val client = HttpAsyncClients.createHttp2Default()
    
        client.use { client ->
          client.start()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  9. src/main/assemblies/files/fess.in.sh

    #!/bin/sh
    
    FESS_CLASSPATH=$FESS_HOME/lib/classes
    
    # JAVA_OPTS is not a built-in JVM mechanism but some people think it is so we
    # warn them that we are not observing the value of $JAVA_OPTS
    if [ ! -z "$JAVA_OPTS" ]; then
      echo -n "warning: ignoring JAVA_OPTS=$JAVA_OPTS; "
      echo "pass JVM parameters via FESS_JAVA_OPTS"
    fi
    
    if [ "x$FESS_MIN_MEM" = "x" ]; then
        FESS_MIN_MEM=256m
    fi
    if [ "x$FESS_MAX_MEM" = "x" ]; then
        FESS_MAX_MEM=2g
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sun Jan 15 06:32:15 UTC 2023
    - 4.7K bytes
    - Viewed (0)
  10. docs/contribute/concurrency.md

    Consider an application streaming a video over http/2. Perhaps the user pauses the video and the application stops reading bytes from this stream. The buffer will fill up, and flow control prevents the server from sending more data on this stream. When the user unpauses her video the buffer drains, the read is acknowledged, and the server proceeds to stream data.
    
    #### Shared reader thread
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 16:35:36 UTC 2022
    - 7K bytes
    - Viewed (0)
Back to top