Search Options

Results per page
Sort
Preferred Languages
Advance

Results 821 - 830 of 1,027 for jstream (0.16 sec)

  1. okhttp/src/jvmTest/kotlin/okhttp3/CacheTest.kt

    import java.text.SimpleDateFormat
    import java.util.Date
    import java.util.Locale
    import java.util.TimeZone
    import java.util.concurrent.TimeUnit
    import java.util.concurrent.atomic.AtomicReference
    import java.util.stream.Stream
    import javax.net.ssl.HostnameVerifier
    import kotlin.test.assertFailsWith
    import mockwebserver3.MockResponse
    import mockwebserver3.MockWebServer
    import mockwebserver3.RecordedRequest
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Oct 03 17:41:45 UTC 2025
    - 116.8K bytes
    - Viewed (0)
  2. guava/src/com/google/common/collect/ImmutableSet.java

      /**
       * Returns a {@code Collector} that accumulates the input elements into a new {@code
       * ImmutableSet}. Elements appear in the resulting set in the encounter order of the stream; if
       * the stream contains duplicates (according to {@link Object#equals(Object)}), only the first
       * duplicate in encounter order will appear in the result.
       *
       * @since 21.0
       */
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Nov 07 16:09:47 UTC 2025
    - 35.3K bytes
    - Viewed (0)
  3. docs/bucket/replication/DESIGN.md

          "x-minio-internal-tier-free-versionID": "OWZlZjk5N2QtMjMzZi00N2U3LTlkZmMtNWYxNzc3NzdlZTM2"
        },
        "MetaUsr": {
          "X-Amz-Replication-Status": "COMPLETED",
          "content-type": "application/octet-stream",
          "etag": "8315e643ed6a5d7c9962fc0a8ef9c11f"
        },
    ...
    ```
    
    ### Metadata for object replication - on target
    
    ```
    ...
      "MetaSys": {
          "x-minio-internal-inline-data": "dHJ1ZQ==",
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 14.7K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/cache/LocalCacheMapComputeTest.java

    import java.util.List;
    import java.util.Queue;
    import java.util.concurrent.ConcurrentLinkedQueue;
    import java.util.concurrent.ExecutionException;
    import java.util.function.IntConsumer;
    import java.util.stream.IntStream;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    /** Test Java8 map.compute in concurrent cache context. */
    @NullUnmarked
    public class LocalCacheMapComputeTest extends TestCase {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 30 22:03:28 UTC 2025
    - 7K bytes
    - Viewed (0)
  5. src/main/java/jcifs/internal/smb2/nego/Smb2NegotiateRequest.java

                    ciphers.add(EncryptionNegotiateContext.CIPHER_AES128_GCM);
                    ciphers.add(EncryptionNegotiateContext.CIPHER_AES128_CCM);
    
                    int[] cipherArray = ciphers.stream().mapToInt(Integer::intValue).toArray();
                    negoContexts.add(new EncryptionNegotiateContext(config, cipherArray));
                }
    
                // Add compression context for SMB3 compression support
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 9.3K bytes
    - Viewed (0)
  6. fastapi/routing.py

                type[Response],
                Doc(
                    """
                    The default response class to be used.
    
                    Read more in the
                    [FastAPI docs for Custom Response - HTML, Stream, File, others](https://fastapi.tiangolo.com/advanced/custom-response/#default-response-class).
                    """
                ),
            ] = Default(JSONResponse),
            responses: Annotated[
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sat Dec 27 12:54:56 UTC 2025
    - 174.6K bytes
    - Viewed (0)
  7. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/PlexusContainerCapsuleFactory.java

                    coreEntry.getExportedArtifacts(),
                    coreExtensionSelector.selectCoreExtensions(invoker, context));
            List<CoreExtensionEntry> loadedExtensionsEntries =
                    loadedExtensions.stream().map(LoadedCoreExtension::entry).toList();
            ClassRealm containerRealm =
                    setupContainerRealm(context.logger, classWorld, coreRealm, extClassPath, loadedExtensionsEntries);
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Thu Jul 03 14:18:26 UTC 2025
    - 14.3K bytes
    - Viewed (0)
  8. internal/grid/msg.go

    	OpMuxServerMsg
    
    	// OpUnblockSrvMux contains a message that a server mux is unblocked with one.
    	// Only Stateful streams has flow control.
    	OpUnblockSrvMux
    
    	// OpUnblockClMux contains a message that a client mux is unblocked with one.
    	// Only Stateful streams has flow control.
    	OpUnblockClMux
    
    	// OpAckMux acknowledges a mux was created.
    	OpAckMux
    
    	// OpRequest is a single request + response.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Jul 25 21:07:21 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  9. guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/ImmutableSortedMap.java

    import java.util.Iterator;
    import java.util.Map;
    import java.util.SortedMap;
    import java.util.TreeMap;
    import java.util.function.BinaryOperator;
    import java.util.function.Function;
    import java.util.stream.Collector;
    import java.util.stream.Collectors;
    import org.jspecify.annotations.Nullable;
    
    /**
     * GWT emulated version of {@link com.google.common.collect.ImmutableSortedMap}. It's a thin wrapper
     * around a {@link java.util.TreeMap}.
     *
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 22 21:07:18 UTC 2025
    - 16.1K bytes
    - Viewed (0)
  10. src/test/java/jcifs/util/ResourceManagerTest.java

            var activeResources = resourceManager.getActiveResources();
            assertNotNull(activeResources);
            assertFalse(activeResources.isEmpty());
    
            boolean found = activeResources.stream().anyMatch(desc -> desc.contains("TestResource"));
            assertTrue(found);
        }
    
        @Test
        @DisplayName("Test multiple close calls on managed resource")
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 8.9K bytes
    - Viewed (0)
Back to top