Search Options

Results per page
Sort
Preferred Languages
Advance

Results 771 - 780 of 1,909 for Pong (0.04 sec)

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

         */
        @SuppressWarnings("GoodTime") // should accept a java.time.Duration
        public static Scheduler newFixedDelaySchedule(
            final long initialDelay, final long delay, final TimeUnit unit) {
          checkNotNull(unit);
          checkArgument(delay > 0, "delay must be > 0, found %s", delay);
          return new Scheduler() {
            @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 16:22:21 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  2. okhttp-sse/src/main/kotlin/okhttp3/sse/internal/ServerSentEventReader.kt

    ) {
      private var lastId: String? = null
    
      interface Callback {
        fun onEvent(
          id: String?,
          type: String?,
          data: String,
        )
    
        fun onRetryChange(timeMs: Long)
      }
    
      /**
       * Process the next event. This will result in a single call to [Callback.onEvent] *unless* the
       * data section was empty. Any number of calls to [Callback.onRetryChange] may occur while
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/io/MultiInputStreamTest.java

                          public InputStream openStream() {
                            return new ByteArrayInputStream(newPreFilledByteArray(0, 50)) {
                              @Override
                              public long skip(long n) {
                                return 0;
                              }
                            };
                          }
                        })
                    .iterator());
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 4.6K bytes
    - Viewed (0)
  4. okhttp-testing-support/src/main/kotlin/okhttp3/RecordingEventListener.kt

      private val forbiddenLocks = mutableListOf<Any>()
    
      /** The timestamp of the last taken event, used to measure elapsed time between events. */
      private var lastTimestampNs: Long? = null
    
      /** Confirm that the thread does not hold a lock on `lock` during the callback. */
      fun forbidLock(lock: Any) {
        forbiddenLocks.add(lock)
      }
    
      /**
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 9K bytes
    - Viewed (0)
  5. docs_src/query_params/tutorial003.py

        item = {"item_id": item_id}
        if q:
            item.update({"q": q})
        if not short:
            item.update(
                {"description": "This is an amazing item that has a long description"}
            )
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sat May 14 11:59:59 UTC 2022
    - 406 bytes
    - Viewed (0)
  6. src/main/java/jcifs/smb1/netbios/Lmhosts.java

    public class Lmhosts {
    
        private static final String FILENAME = Config.getProperty( "jcifs.smb1.netbios.lmhosts" );
        private static final Hashtable TAB = new Hashtable();
        private static long lastModified = 1L;
        private static int alt;
        private static LogStream log = LogStream.getInstance();
    
        /**
         * This is really just for {@link jcifs.smb1.UniAddress}. It does
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 5.8K bytes
    - Viewed (0)
  7. mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt

       */
      val requestCount: Int
        get() = atomicRequestCount.get()
    
      /** The number of bytes of the POST body to keep in memory to the given limit. */
      var bodyLimit: Long = Long.MAX_VALUE
    
      var serverSocketFactory: ServerSocketFactory? = null
        @Synchronized get() {
          if (field == null && started) {
            field = ServerSocketFactory.getDefault() // Build the default value lazily.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Mar 31 17:16:15 UTC 2024
    - 37.4K bytes
    - Viewed (0)
  8. samples/guide/src/main/java/okhttp3/recipes/CancelCall.java

      public void run() throws Exception {
        Request request = new Request.Builder()
            .url("http://httpbin.org/delay/2") // This URL is served with a 2 second delay.
            .build();
    
        final long startNanos = System.nanoTime();
        final Call call = client.newCall(request);
    
        // Schedule a job to cancel the call in 1 second.
        executor.schedule(() -> {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 12 03:31:36 UTC 2019
    - 2.1K bytes
    - Viewed (0)
  9. guava/src/com/google/common/collect/ImmutableAsList.java

        SerializedForm(ImmutableCollection<?> collection) {
          this.collection = collection;
        }
    
        Object readResolve() {
          return collection.asList();
        }
    
        private static final long serialVersionUID = 0;
      }
    
      @GwtIncompatible // serialization
      @J2ktIncompatible
      private void readObject(ObjectInputStream stream) throws InvalidObjectException {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Mar 06 16:06:58 UTC 2023
    - 2.6K bytes
    - Viewed (0)
  10. guava/src/com/google/common/collect/TreeMultiset.java

          }
        };
    
        abstract int nodeAggregate(AvlNode<?> node);
    
        abstract long treeAggregate(@CheckForNull AvlNode<?> root);
      }
    
      private long aggregateForEntries(Aggregate aggr) {
        AvlNode<E> root = rootReference.get();
        long total = aggr.treeAggregate(root);
        if (range.hasLowerBound()) {
          total -= aggregateBelowRange(aggr, root);
        }
        if (range.hasUpperBound()) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 20:24:49 UTC 2024
    - 34.5K bytes
    - Viewed (0)
Back to top