Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 1,102 for Stream (0.04 sec)

  1. 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)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Reader.kt

         * weight from the default (16) to a new value.
         *
         * @param streamId stream which has a priority change.
         * @param streamDependency the stream ID this stream is dependent on.
         * @param weight relative proportion of priority in `[1..256]`.
         * @param exclusive inserts this stream ID as the sole child of `streamDependency`.
         */
        fun priority(
          streamId: Int,
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 19.8K bytes
    - Viewed (0)
  3. 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)
  4. src/main/java/org/codelibs/fess/sso/entraid/EntraIdAuthenticator.java

                return;
            }
            final Pair<String[], String[]> groupsAndRoles = getParentGroup(user, id, depth);
            StreamUtil.stream(groupsAndRoles.getFirst()).of(stream -> stream.forEach(groupList::add));
            StreamUtil.stream(groupsAndRoles.getSecond()).of(stream -> stream.forEach(roleList::add));
            if (logger.isDebugEnabled()) {
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Sat Dec 13 02:21:17 UTC 2025
    - 56.7K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. src/main/java/jcifs/SmbPipeHandle.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
         */
        InputStream getInput() throws CIFSException;
    
        /**
         * Gets the output stream for writing to this pipe.
         *
         * @return this pipe's output stream
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 2.4K bytes
    - Viewed (0)
  10. fess-crawler/src/main/java/org/codelibs/fess/crawler/util/TemporaryFileInputStream.java

     * is deleted when the stream is closed.
     */
    public class TemporaryFileInputStream extends InputStream {
    
        private final File tempFile;
    
        private final FileInputStream fileInputStream;
    
        /**
         * A class that provides an input stream for reading from a temporary file.
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sat Nov 22 13:28:22 UTC 2025
    - 4.1K bytes
    - Viewed (0)
Back to top