Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 105 for Relay (0.4 sec)

  1. guava/src/com/google/common/util/concurrent/ListeningScheduledExecutorService.java

      @Override
      ListenableScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit);
    
      /**
       * Duration-based overload of {@link #schedule(Runnable, long, TimeUnit)}.
       *
       * @since 29.0
       */
      @J2ktIncompatible
      default ListenableScheduledFuture<?> schedule(Runnable command, Duration delay) {
        return schedule(command, toNanosSaturated(delay), TimeUnit.NANOSECONDS);
      }
    
      /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue Feb 11 17:30:04 UTC 2025
    - 3.6K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

            this.delay = delay;
            this.unit = checkNotNull(unit);
          }
    
          /**
           * @param delay the time from now to delay execution
           * @since 33.4.0 (but since 31.1 in the JRE flavor)
           */
          @IgnoreJRERequirement // Users will use this only if they're already using Duration
          public Schedule(Duration delay) {
            this(toNanosSaturated(delay), NANOSECONDS);
          }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.7K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/WrappingScheduledExecutorService.java

      }
    
      @Override
      public final ScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) {
        return delegate.schedule(wrapTask(command), delay, unit);
      }
    
      @Override
      public final <V extends @Nullable Object> ScheduledFuture<V> schedule(
          Callable<V> task, long delay, TimeUnit unit) {
        return delegate.schedule(wrapTask(task), delay, unit);
      }
    
      @Override
      public final ScheduledFuture<?> scheduleAtFixedRate(
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/WrappingScheduledExecutorService.java

      }
    
      @Override
      public final ScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) {
        return delegate.schedule(wrapTask(command), delay, unit);
      }
    
      @Override
      public final <V extends @Nullable Object> ScheduledFuture<V> schedule(
          Callable<V> task, long delay, TimeUnit unit) {
        return delegate.schedule(wrapTask(task), delay, unit);
      }
    
      @Override
      public final ScheduledFuture<?> scheduleAtFixedRate(
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  5. mockwebserver/src/main/kotlin/mockwebserver3/MockResponse.kt

          }
    
        public fun headersDelay(
          delay: Long,
          unit: TimeUnit,
        ): Builder =
          apply {
            headersDelayNanos = unit.toNanos(delay)
          }
    
        /**
         * Set the delayed time of the response body to [delay]. This applies to the response body
         * only; response headers are not affected.
         */
        public fun bodyDelay(
          delay: Long,
          unit: TimeUnit,
        ): Builder =
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 17.8K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java

          String message = "inputFuture=[" + localInputFuture + "]";
          if (localTimer != null) {
            long delay = localTimer.getDelay(MILLISECONDS);
            // Negative delays look confusing in an error message
            if (delay > 0) {
              message += ", remaining delay=[" + delay + " ms]";
            }
          }
          return message;
        }
        return null;
      }
    
      @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 8K bytes
    - Viewed (0)
  7. android/guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java

        @Override
        public <V> ListenableScheduledFuture<V> schedule(
            Callable<V> callable, long delay, TimeUnit unit) {
          return NeverScheduledFuture.create();
        }
    
        @Override
        public ListenableScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) {
          return NeverScheduledFuture.create();
        }
    
        @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Jul 17 15:26:41 UTC 2025
    - 6.6K bytes
    - Viewed (0)
  8. mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/MockResponse.kt

      fun setBodyDelay(
        delay: Long,
        unit: TimeUnit,
      ) = apply {
        bodyDelayAmount = delay
        bodyDelayUnit = unit
      }
    
      fun getBodyDelay(unit: TimeUnit): Long = unit.convert(bodyDelayAmount, bodyDelayUnit)
    
      fun setHeadersDelay(
        delay: Long,
        unit: TimeUnit,
      ) = apply {
        headersDelayAmount = delay
        headersDelayUnit = unit
      }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat May 10 11:15:14 UTC 2025
    - 7.1K bytes
    - Viewed (0)
  9. android/guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java

      public ListenableScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) {
        Preconditions.checkNotNull(command, "command must not be null");
        Preconditions.checkNotNull(unit, "unit must not be null!");
        return schedule(callable(command), delay, unit);
      }
    
      @Override
      public <V> ListenableScheduledFuture<V> schedule(
          Callable<V> callable, long delay, TimeUnit unit) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:37:28 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  10. guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java

      public ListenableScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) {
        Preconditions.checkNotNull(command, "command must not be null");
        Preconditions.checkNotNull(unit, "unit must not be null!");
        return schedule(callable(command), delay, unit);
      }
    
      @Override
      public <V> ListenableScheduledFuture<V> schedule(
          Callable<V> callable, long delay, TimeUnit unit) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:37:28 UTC 2025
    - 6.5K bytes
    - Viewed (0)
Back to top