Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 131 - 140 of 407 for stopfn (0.12 seconds)

  1. ci/devinfra/docker/windows/Dockerfile

    # - Python 3.12.3
    # - Bazelisk 1.19.0
    # - JDK 21 (Azul Zulu)
    
    FROM mcr.microsoft.com/windows/servercore:ltsc2019
    
    SHELL ["powershell.exe", "-ExecutionPolicy", "Bypass", "-Command", \
           "$ErrorActionPreference='Stop'; $ProgressPreference='SilentlyContinue';$VerbosePreference = 'Continue';"]
    
    # This should only be necessary when running on A GCP VM, on a default
    # network, which has the MTU of 1460,
    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Fri Jan 17 16:35:57 GMT 2025
    - 8.4K bytes
    - Click Count (0)
  2. guava/src/com/google/common/collect/EmptyImmutableSetMultimap.java

      /*
       * TODO(b/242884182): Figure out why this helps produce the same class file when we compile most
       * of common.collect a second time with the results of the first compilation on the classpath. Or
       * just back this out once we stop doing that (which we'll do after our internal GWT setup
       * changes).
       */
      @Override
      public ImmutableMap<Object, Collection<Object>> asMap() {
        return super.asMap();
      }
    
      private Object readResolve() {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Sep 22 21:07:18 GMT 2025
    - 1.8K bytes
    - Click Count (0)
  3. samples/compare/src/test/kotlin/okhttp3/compare/JettyHttpClientTest.kt

      private val client = HttpClient()
    
      @StartStop
      private val server = MockWebServer()
    
      @BeforeEach fun setUp() {
        client.start()
      }
    
      @AfterEach fun tearDown() {
        client.stop()
      }
    
      @Test fun get() {
        server.enqueue(MockResponse(body = "hello, Jetty HTTP Client"))
    
        val request =
          client
            .newRequest(server.url("/").toUri())
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Jun 18 12:28:21 GMT 2025
    - 2.1K bytes
    - Click Count (0)
  4. guava/src/com/google/common/base/Splitter.java

       */
      public Splitter omitEmptyStrings() {
        return new Splitter(strategy, true, trimmer, limit);
      }
    
      /**
       * Returns a splitter that behaves equivalently to {@code this} splitter but stops splitting after
       * it reaches the limit. The limit defines the maximum number of items returned by the iterator,
       * or the maximum size of the list returned by {@link #splitToList}.
       *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 23.8K bytes
    - Click Count (0)
  5. android/guava-testlib/test/com/google/common/collect/testing/OpenJdk6MapTests.java

         * changes: https://mail.openjdk.org/pipermail/core-libs-dev/2013-May/thread.html#17367
         *
         * TODO(cpovirk): decide what the best long-term action here is: force users
         * to suppress (as we do now), stop testing entrySet().add() at all, make
         * entrySet().add() tests tolerant of either behavior, introduce a map
         * feature for entrySet() that supports add(), or something else
         */
        return asList(
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue May 13 17:27:14 GMT 2025
    - 3.9K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/base/Ascii.java

      /**
       * Device Control 1. Characters for the control of ancillary devices associated with data
       * processing or telecommunication systems, more especially switching devices "on" or "off." (If a
       * single "stop" control is required to interrupt or turn off ancillary devices, DC4 is the
       * preferred assignment.)
       *
       * @since 8.0
       */
      public static final byte DC1 = 17; // aka XON
    
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 17 20:26:29 GMT 2025
    - 21.7K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java

     *
     * <p>{@code RuntimeException}s thrown by tasks are simply logged and the executor keeps trucking.
     * If an {@code Error} is thrown, the error will propagate and execution will stop until it is
     * restarted by a call to {@link #execute}.
     */
    @J2ktIncompatible
    @GwtIncompatible
    final class SequentialExecutor implements Executor {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 10.6K bytes
    - Click Count (0)
  8. api/maven-api-cli/src/main/java/org/apache/maven/api/cli/mvn/MavenOptions.java

         */
        @Nonnull
        Optional<Boolean> relaxedChecksums();
    
        /**
         * Indicates whether Maven should stop at the first failure in a multi-module build.
         *
         * @return an {@link Optional} containing true if Maven should stop at the first failure, false if not, or empty if not specified
         */
        @Nonnull
        Optional<Boolean> failFast();
    
        /**
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Jun 11 13:14:09 GMT 2025
    - 8K bytes
    - Click Count (0)
  9. internal/deadlineconn/deadlineconn.go

    	defer c.mu.Unlock()
    	c.abortWrites.Store(!t.IsZero() && time.Until(t) < 0)
    	c.infWrites.Store(t.IsZero())
    	c.writeSetAt = time.Time{}
    	return c.Conn.SetWriteDeadline(t)
    }
    
    // Close wraps conn.Close and stops sending deadline updates.
    func (c *DeadlineConn) Close() error {
    	c.abortReads.Store(true)
    	c.abortWrites.Store(true)
    	return c.Conn.Close()
    }
    
    // WithReadDeadline sets a new read side net.Conn deadline.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Dec 02 13:21:17 GMT 2024
    - 5.1K bytes
    - Click Count (0)
  10. src/main/java/org/codelibs/fess/opensearch/config/exentity/ScheduledJob.java

                    });
                } else {
                    job.launchNow();
                }
            }).orElse(() -> {
                throw new JobNotFoundException(this);
            });
        }
    
        public void stop() {
            ComponentUtil.getJobManager().findJobByUniqueOf(LaJobUnique.of(getId())).ifPresent(job -> {
                job.stopNow();
            }).orElse(() -> {
                throw new JobNotFoundException(this);
            });
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 28 11:55:54 GMT 2026
    - 3.6K bytes
    - Click Count (0)
Back to Top