Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 1,030 for stream (0.04 sec)

  1. src/main/java/org/codelibs/fess/app/web/admin/log/AdminLogAction.java

            final String logFilePath = systemHelper.getLogFilePath();
            if (StringUtil.isNotBlank(logFilePath)) {
                final Path logDirPath = Paths.get(logFilePath);
                try (Stream<Path> stream = Files.list(logDirPath)) {
                    stream.filter(entry -> isLogFilename(entry.getFileName().toString())).sorted().forEach(filePath -> {
                        final Map<String, Object> map = new HashMap<>();
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 5.5K bytes
    - Viewed (0)
  2. src/test/java/jcifs/smb1/netbios/SocketInputStreamTest.java

            assertThrows(IOException.class, () -> sis.read());
        }
    
        @Test
        @DisplayName("Available returns underlying stream available when no message buffered")
        void availableReturnsUnderlyingWhenNoMessage() throws IOException {
            // Mock input stream that reports available bytes
            InputStream mockIn = mock(InputStream.class);
            when(mockIn.available()).thenReturn(42);
    
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 14.2K bytes
    - Viewed (0)
  3. impl/maven-cli/src/test/java/org/apache/maven/cling/transfer/FileSizeFormatTest.java

     * specific language governing permissions and limitations
     * under the License.
     */
    package org.apache.maven.cling.transfer;
    
    import java.util.Locale;
    import java.util.stream.Stream;
    
    import org.apache.maven.api.services.MessageBuilder;
    import org.apache.maven.cling.transfer.FileSizeFormat.ScaleUnit;
    import org.apache.maven.impl.DefaultMessageBuilder;
    import org.junit.jupiter.api.AfterAll;
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Mar 21 04:56:21 UTC 2025
    - 14.9K bytes
    - Viewed (0)
  4. impl/maven-core/src/main/java/org/apache/maven/internal/impl/DefaultArtifactManager.java

            }
        }
    
        /**
         * Retrieve a stream of the project's artifacts.
         * Do not include the POM artifact as the file can't be set anyway.
         */
        private Stream<org.apache.maven.artifact.Artifact> getProjectArtifacts(MavenProject project) {
            return Stream.concat(Stream.of(project.getArtifact()), project.getAttachedArtifacts().stream());
        }
    
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Wed Sep 17 16:01:38 UTC 2025
    - 4.4K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/auth/AuthenticationManager.java

            return chains().get(stream -> stream.allMatch(c -> c.changePassword(username, password)));
        }
    
        /**
         * Deletes a user from all authentication chains.
         * @param user The user to delete.
         */
        public void delete(final User user) {
            chains().of(stream -> stream.forEach(c -> c.delete(user)));
        }
    
        /**
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 3.1K bytes
    - Viewed (0)
  6. cmd/object-api-utils_test.go

    			metadata: map[string]string{"content-type": "application/octet-stream", "etag": "de75a98baf2c6aef435b57dd0fc33c86", "x-amz-storage-class": "STANDARD"},
    			want:     map[string]string{"content-type": "application/octet-stream", "etag": "de75a98baf2c6aef435b57dd0fc33c86"},
    		},
    		{
    			name:     "2",
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 24.1K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/ds/AbstractDataStore.java

     * governing permissions and limitations under the License.
     */
    package org.codelibs.fess.ds;
    
    import static org.codelibs.core.stream.StreamUtil.stream;
    
    import java.util.ArrayList;
    import java.util.Date;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    import java.util.stream.Collectors;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 7.6K bytes
    - Viewed (0)
  8. src/test/java/jcifs/smb/SmbAuthExceptionTest.java

    import static org.junit.jupiter.api.Assertions.assertNull;
    import static org.junit.jupiter.api.Assertions.assertSame;
    import static org.junit.jupiter.api.Assertions.assertTrue;
    
    import java.util.stream.Stream;
    
    import org.junit.jupiter.api.DisplayName;
    import org.junit.jupiter.api.Test;
    import org.junit.jupiter.api.extension.ExtendWith;
    import org.junit.jupiter.params.ParameterizedTest;
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 4.3K bytes
    - Viewed (0)
  9. impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/concurrent/BuildPlan.java

        }
    
        public Stream<BuildStep> steps(MavenProject project) {
            return Optional.ofNullable(plan.get(project))
                    .map(m -> m.values().stream())
                    .orElse(Stream.empty());
        }
    
        public Optional<BuildStep> step(MavenProject project, String name) {
            return Optional.ofNullable(plan.get(project)).map(m -> m.get(name));
        }
    
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Mar 28 12:11:25 UTC 2025
    - 6.1K bytes
    - Viewed (0)
  10. impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/concurrent/BuildStep.java

            }
        }
    
        public void executeBefore(BuildStep stepToExecuteAfter) {
            stepToExecuteAfter.executeAfter(this);
        }
    
        public Stream<MojoExecution> executions() {
            return mojos.values().stream().flatMap(m -> m.values().stream());
        }
    
        @Override
        public boolean equals(Object o) {
            if (this == o) {
                return true;
            }
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Wed Apr 30 16:21:08 UTC 2025
    - 4.9K bytes
    - Viewed (0)
Back to top