Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 191 - 200 of 286 for lett (0.23 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. .teamcity/src/main/kotlin/model/FunctionalTestBucketGenerator.kt

                            it.arch == testCoverage.arch &&
                            it.buildJvm == testCoverage.buildJvm
                    }
                foundTestCoverage
                    ?.let {
                        buildProjectClassTimes[it.asId(MASTER_CHECK_CONFIGURATION)]
                    }?.also {
                        println(
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Thu Apr 10 15:09:32 GMT 2025
    - 7.3K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java

        if (seenExceptionsLocal == null) {
          // TODO(cpovirk): Should we use a simpler (presumably cheaper) data structure?
          /*
           * Using weak references here could let us release exceptions earlier, but:
           *
           * 1. On Android, querying a WeakReference blocks if the GC is doing an otherwise-concurrent
           * pass.
           *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 8.5K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/collect/MoreCollectors.java

       */
      @SuppressWarnings("unchecked")
      public static <T extends @Nullable Object> Collector<T, ?, T> onlyElement() {
        return (Collector) ONLY_ELEMENT;
      }
    
      /**
       * This atrocity is here to let us report several of the elements in the stream if there were more
       * than one, not just two.
       */
      @SuppressWarnings("EmptyList") // ImmutableList doesn't support nullable element types
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Feb 18 16:22:33 GMT 2026
    - 6.3K bytes
    - Click Count (0)
  4. okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

              val coordinatorTask = waitingCoordinatorTask ?: error("no coordinator waiting")
              currentTask = coordinatorTask
              taskRunner.notifyAll()
            }
          }
    
        // Let the coordinator process its interruption.
        runTasks()
      }
    
      /** Ask a single task to proceed. Used by the test thread only. */
      fun runNextTask() {
        taskRunner.assertLockNotHeld()
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed May 28 23:28:25 GMT 2025
    - 11.9K bytes
    - Click Count (0)
  5. okhttp-logging-interceptor/src/main/kotlin/okhttp3/logging/HttpLoggingInterceptor.kt

              // Request body headers are only present when installed as a network interceptor. When not
              // already present, force them to be included (if available) so their values are known.
              requestBody.contentType()?.let {
                if (headers["Content-Type"] == null) {
                  logger.log("Content-Type: $it")
                }
              }
              if (requestBody.contentLength() != -1L) {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri Nov 07 02:57:33 GMT 2025
    - 11.5K bytes
    - Click Count (0)
  6. android/guava-tests/test/com/google/common/reflect/TypeTokenTest.java

      private static void assertSubtypeTokenBeforeSupertypeToken(
          Iterable<? extends TypeToken<?>> types) {
        int i = 0;
        for (TypeToken<?> left : types) {
          int j = 0;
          for (TypeToken<?> right : types) {
            if (left.isSupertypeOf(right)) {
              assertTrue(left + " should be after " + right, i >= j);
            }
            j++;
          }
          i++;
        }
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 89.3K bytes
    - Click Count (0)
  7. guava/src/com/google/common/collect/MoreCollectors.java

       */
      @SuppressWarnings("unchecked")
      public static <T extends @Nullable Object> Collector<T, ?, T> onlyElement() {
        return (Collector) ONLY_ELEMENT;
      }
    
      /**
       * This atrocity is here to let us report several of the elements in the stream if there were more
       * than one, not just two.
       */
      @SuppressWarnings("EmptyList") // ImmutableList doesn't support nullable element types
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Feb 18 16:22:33 GMT 2026
    - 6.1K bytes
    - Click Count (0)
  8. guava-tests/test/com/google/common/collect/ImmutableListMultimapTest.java

        builder.put("bb", 3);
        builder.put("d", 2);
        builder.put("a", 5);
        builder.orderKeysBy(
            new Ordering<String>() {
              @Override
              public int compare(String left, String right) {
                return left.length() - right.length();
              }
            });
        builder.put("cc", 4);
        builder.put("a", 2);
        builder.put("bb", 6);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 26.1K bytes
    - Click Count (0)
  9. guava/src/com/google/common/collect/AbstractMapBasedMultiset.java

        implements Serializable {
      // TODO(lowasser): consider overhauling this back to Map<E, Integer>
      private transient Map<E, Count> backingMap;
    
      /*
       * Cache the size for efficiency. Using a long lets us avoid the need for
       * overflow checking and ensures that size() will function correctly even if
       * the multiset had once been larger than Integer.MAX_VALUE.
       */
      private transient long size;
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Aug 11 19:31:30 GMT 2025
    - 10.2K bytes
    - Click Count (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/CacheInterceptor.kt

            }
          }
        }
    
        return response
      }
    
      /**
       * Returns a new source that writes bytes to [cacheRequest] as they are read by the source
       * consumer. This is careful to discard bytes left over when the stream is closed; otherwise we
       * may never exhaust the source stream and therefore not complete the cached response.
       */
      @Throws(IOException::class)
      private fun cacheWritingResponse(
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Jan 11 12:06:21 GMT 2026
    - 10.3K bytes
    - Click Count (0)
Back to Top