Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 381 - 390 of 1,211 for streams (0.05 seconds)

  1. build-conventions/src/main/java/org/elasticsearch/gradle/internal/conventions/precommit/LicenseHeadersTask.java

                    .newDocumentBuilder()
                    .parse(xmlReportFile)
                    .getElementsByTagName("resource");
                return elementList(resourcesNodes).stream()
                    .filter(
                        resource -> elementList(resource.getChildNodes()).stream()
                            .anyMatch(n -> n.getTagName().equals("license-approval") && n.getAttribute("name").equals("false"))
                    )
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Thu Sep 09 18:53:35 GMT 2021
    - 10.6K bytes
    - Click Count (0)
  2. src/main/java/org/codelibs/fess/helper/VirtualHostHelper.java

         * Gets all configured virtual host paths.
         *
         * @return An array of virtual host paths
         */
        public String[] getVirtualHostPaths() {
            return stream(ComponentUtil.getFessConfig().getVirtualHosts())
                    .get(stream -> stream.map(h -> "/" + h.getValue3()).toArray(n -> new String[n]));
        }
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 4.2K bytes
    - Click Count (0)
  3. src/main/java/org/codelibs/fess/helper/ThemeHelper.java

    import java.nio.file.StandardCopyOption;
    import java.util.Comparator;
    import java.util.stream.Stream;
    import java.util.zip.ZipEntry;
    import java.util.zip.ZipInputStream;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.lang.StringUtil;
    import org.codelibs.core.stream.StreamUtil;
    import org.codelibs.fess.exception.ThemeException;
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 7.1K bytes
    - Click Count (0)
  4. impl/maven-core/src/main/java/org/apache/maven/lifecycle/DefaultLifecycles.java

                        ? registry.stream().collect(Collectors.toMap(lf -> lf.id(), lf -> new Lifecycle(registry, lf)))
                        : Map.of();
            } catch (LookupException e) {
                throw new IllegalStateException("Unable to lookup lifecycles from the plexus container", e);
            }
        }
    
        public String getLifecyclePhaseList() {
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Sat Apr 05 11:52:05 GMT 2025
    - 6.6K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/io/CountingOutputStream.java

     */
    @J2ktIncompatible
    @GwtIncompatible
    public final class CountingOutputStream extends FilterOutputStream {
    
      private long count;
    
      /**
       * Wraps another output stream, counting the number of bytes written.
       *
       * @param out the output stream to be wrapped
       */
      public CountingOutputStream(OutputStream out) {
        super(checkNotNull(out));
      }
    
      /** Returns the number of bytes written. */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Dec 21 03:10:51 GMT 2024
    - 1.9K bytes
    - Click Count (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2Test.kt

      }
    
      @Test fun streamIdHasReservedBit() {
        val writer = Http2Writer(Buffer(), true)
        assertFailsWith<IllegalArgumentException> {
          var streamId = 3
          streamId = streamId or (1L shl 31).toInt() // set reserved bit
          writer.frameHeader(streamId, Http2.INITIAL_MAX_FRAME_SIZE, Http2.TYPE_DATA, FLAG_NONE)
        }.also { expected ->
          assertThat(expected.message).isEqualTo("reserved bit set: -2147483645")
        }
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 28.1K bytes
    - Click Count (0)
  7. impl/maven-core/src/main/java/org/apache/maven/DefaultMaven.java

                }
            }
    
            final Stream<String> projectProfiles = projectsIncludingParents.stream()
                    .flatMap(p -> p.getModel().getDelegate().getProfiles().stream())
                    .map(Profile::getId);
            final Stream<String> settingsProfiles =
                    session.getSettings().getProfiles().stream().map(org.apache.maven.settings.Profile::getId);
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Mon Dec 29 10:43:38 GMT 2025
    - 28.8K bytes
    - Click Count (1)
  8. src/main/java/jcifs/smb/SmbPipeHandleInternal.java

        /**
         * Gets the input stream for reading from this pipe.
         *
         * @return this pipe's input stream
         * @throws CIFSException if an error occurs getting the input stream
         */
        @Override
        SmbPipeInputStream getInput() throws CIFSException;
    
        /**
         *
         * @return this pipe's output stream
         * @throws CIFSException if an error occurs
         */
        @Override
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 3.7K bytes
    - Click Count (0)
  9. src/test/java/jcifs/smb1/dcerpc/msrpc/MsrpcSamrConnect2Test.java

    import static org.junit.jupiter.api.Assertions.assertNotNull;
    import static org.junit.jupiter.api.Assertions.assertTrue;
    import static org.mockito.Mockito.mock;
    
    import java.util.stream.Stream;
    
    import org.junit.jupiter.api.DisplayName;
    import org.junit.jupiter.api.Nested;
    import org.junit.jupiter.api.Test;
    import org.junit.jupiter.api.extension.ExtendWith;
    import org.junit.jupiter.params.ParameterizedTest;
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 5.6K bytes
    - Click Count (0)
  10. src/test/java/jcifs/smb1/smb1/NtTransQuerySecurityDescTest.java

    package jcifs.smb1.smb1;
    
    import static org.junit.jupiter.api.Assertions.assertEquals;
    import static org.junit.jupiter.api.Assertions.assertTrue;
    
    import java.nio.ByteBuffer;
    import java.nio.ByteOrder;
    import java.util.stream.Stream;
    
    import org.junit.jupiter.api.Test;
    import org.junit.jupiter.api.extension.ExtendWith;
    import org.junit.jupiter.params.ParameterizedTest;
    import org.junit.jupiter.params.provider.CsvSource;
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 4.6K bytes
    - Click Count (0)
Back to Top