- Sort Score
- Num 10 results
- Language All
Results 1661 - 1670 of 1,852 for collected (0.05 seconds)
-
android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
import static java.util.concurrent.Executors.newSingleThreadExecutor; import static java.util.concurrent.TimeUnit.SECONDS; import static org.junit.Assert.assertThrows; import com.google.common.collect.ImmutableList; import java.util.ArrayDeque; import java.util.ArrayList; import java.util.List; import java.util.Queue; import java.util.concurrent.CountDownLatch; import java.util.concurrent.CyclicBarrier;
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Fri Jul 11 18:52:30 GMT 2025 - 11.4K bytes - Click Count (0) -
android/guava/src/com/google/common/cache/AbstractCache.java
* the License. */ package com.google.common.cache; import com.google.common.annotations.GwtCompatible; import com.google.common.collect.ImmutableMap; import java.util.LinkedHashMap; import java.util.Map; import java.util.Map.Entry; import java.util.concurrent.Callable; import java.util.concurrent.ConcurrentMap;
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue May 13 17:27:14 GMT 2025 - 9.1K bytes - Click Count (0) -
guava/src/com/google/common/collect/ForwardingNavigableSet.java
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package com.google.common.collect; import com.google.common.annotations.GwtIncompatible; import java.util.Iterator; import java.util.NavigableSet; import java.util.SortedSet; import org.jspecify.annotations.Nullable; /**
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 8.8K bytes - Click Count (0) -
guava/src/com/google/common/util/concurrent/FuturesGetChecked.java
import static java.util.Arrays.asList; import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible; import com.google.common.annotations.VisibleForTesting; import com.google.common.collect.Ordering; import com.google.errorprone.annotations.CanIgnoreReturnValue; import com.google.j2objc.annotations.J2ObjCIncompatible; import java.lang.ref.WeakReference; import java.lang.reflect.Constructor;
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sat Aug 09 01:14:59 GMT 2025 - 11.8K bytes - Click Count (0) -
build-logic/binary-compatibility/src/test/groovy/gradlebuild/binarycompatibility/PublicAPIRulesTest.groovy
def jApiMethod = Stub(JApiMethod) jApiMethod.name >> implicitMethod jApiMethod.jApiClass >> jApiClassifier jApiMethod.parameters >> paramTypes.collect { paramStub(it) } when: sourceFile.text = """ public enum $TEST_INTERFACE_SIMPLE_NAME { } """ then:
Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Fri Jun 06 17:52:09 GMT 2025 - 16K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/scheduler/ApiAdminSchedulerAction.java
final List<ScheduledJob> list = scheduledJobService.getScheduledJobList(pager); return asJson( new ApiResult.ApiConfigsResponse<EditBody>().settings(list.stream().map(this::createEditBody).collect(Collectors.toList())) .total(pager.getAllRecordCount()) .status(ApiResult.Status.OK) .result()); } /**
Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Sun Nov 23 12:34:02 GMT 2025 - 10.1K bytes - Click Count (0) -
guava-tests/test/com/google/common/hash/AbstractStreamingHasherTest.java
package com.google.common.hash; import static com.google.common.truth.Truth.assertThat; import static java.nio.charset.StandardCharsets.UTF_16LE; import static org.junit.Assert.assertThrows; import com.google.common.collect.Iterables; import com.google.common.hash.HashTestUtils.RandomHasherAction; import java.io.ByteArrayOutputStream; import java.nio.ByteBuffer; import java.nio.ByteOrder; import java.util.ArrayList; import java.util.Arrays;
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Oct 28 18:19:59 GMT 2025 - 8.6K bytes - Click Count (0) -
guava-tests/test/com/google/common/primitives/UnsignedLongTest.java
import com.google.common.annotations.GwtCompatible; import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible; import com.google.common.collect.ImmutableSet; import com.google.common.testing.EqualsTester; import com.google.common.testing.NullPointerTester; import com.google.common.testing.SerializableTester; import java.math.BigInteger;
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 11 20:45:32 GMT 2025 - 10.4K bytes - Click Count (0) -
src/main/java/jcifs/smb1/smb1/SmbFileInputStream.java
} while (len > 0 && n == r); return (int) (fp - start); } /** * This stream class is unbuffered. Therefore this method will always * return 0 for streams connected to regular files. However, a * stream created from a Named Pipe this method will query the server using a * "peek named pipe" operation and return the number of available bytes * on the server. */
Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 9.4K bytes - Click Count (0) -
cmd/data-scanner-metric.go
var m madmin.ScannerMetrics cycle := p.getCycle() if cycle != nil { m.CurrentCycle = cycle.current m.CyclesCompletedAt = cycle.cycleCompleted m.CurrentStarted = cycle.started } m.CollectedAt = time.Now() m.ActivePaths = p.getCurrentPaths() m.LifeTimeOps = make(map[string]uint64, scannerMetricLast) for i := range scannerMetricLast { if n := atomic.LoadUint64(&p.operations[i]); n > 0 {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Oct 01 06:06:01 GMT 2025 - 9.4K bytes - Click Count (0)