Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 241 - 250 of 1,211 for streams (0.07 seconds)

  1. src/test/java/jcifs/smb1/smb1/SmbAuthExceptionTest.java

    package jcifs.smb1.smb1;
    
    import static org.junit.jupiter.api.Assertions.assertEquals;
    
    import java.util.stream.Stream;
    
    import org.junit.jupiter.api.DisplayName;
    import org.junit.jupiter.api.Test;
    import org.junit.jupiter.params.ParameterizedTest;
    import org.junit.jupiter.params.provider.Arguments;
    import org.junit.jupiter.params.provider.MethodSource;
    
    /**
     * Tests for {@link SmbAuthException}.
     *
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 2.2K bytes
    - Click Count (0)
  2. compat/maven-model/src/test/java/org/apache/maven/model/pom/PomMemoryAnalyzer.java

                long totalOccurrences = stats.values().stream()
                        .mapToLong(StringStats::getOccurrences)
                        .sum();
                long totalMemory = stats.entrySet().stream()
                        .mapToLong(e -> e.getKey().length() * e.getValue().getOccurrences() * 2L)
                        .sum();
                long potentialSavings = stats.entrySet().stream()
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Mar 21 04:56:21 GMT 2025
    - 13.4K bytes
    - Click Count (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2ExchangeCodec.kt

      override fun finishRequest() {
        stream!!.sink.close()
      }
    
      override fun readResponseHeaders(expectContinue: Boolean): Response.Builder? {
        val stream = stream ?: throw IOException("stream wasn't created")
        val headers = stream.takeHeaders(callerIsIdle = expectContinue)
        val responseBuilder = readHttp2HeadersList(headers, protocol)
        return if (expectContinue && responseBuilder.code == HTTP_CONTINUE) {
          null
        } else {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jul 29 21:11:09 GMT 2025
    - 7K bytes
    - Click Count (0)
  4. guava/src/com/google/common/collect/HashMultiset.java

      @J2ktIncompatible
        private void writeObject(ObjectOutputStream stream) throws IOException {
        stream.defaultWriteObject();
        Serialization.writeMultiset(this, stream);
      }
    
      @GwtIncompatible
      @J2ktIncompatible
        private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException {
        stream.defaultReadObject();
        int distinctElements = stream.readInt();
        setBackingMap(new HashMap<>());
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Dec 05 23:15:58 GMT 2025
    - 3.2K bytes
    - Click Count (0)
  5. guava/src/com/google/common/collect/HashMultimap.java

      @GwtIncompatible
      @J2ktIncompatible
        private void writeObject(ObjectOutputStream stream) throws IOException {
        stream.defaultWriteObject();
        Serialization.writeMultimap(this, stream);
      }
    
      @GwtIncompatible
      @J2ktIncompatible
        private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException {
        stream.defaultReadObject();
        expectedValuesPerKey = DEFAULT_VALUES_PER_KEY;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Dec 05 23:15:58 GMT 2025
    - 5.8K bytes
    - Click Count (0)
  6. src/main/java/org/codelibs/fess/entity/SearchRequestParams.java

                return true;
            }
            return stream(values).get(stream -> stream.allMatch(StringUtil::isBlank));
        }
    
        /**
         * Simplifies the array.
         *
         * @param values The array.
         * @return The simplified array.
         */
        protected static String[] simplifyArray(final String[] values) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 8K bytes
    - Click Count (0)
  7. 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)));
        }
    
        /**
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 3.1K bytes
    - Click Count (0)
  8. src/main/java/org/codelibs/fess/mylasta/action/FessUserBean.java

        }
    
        public boolean hasRole(final String role) {
            return stream(user.getRoleNames()).get(stream -> stream.anyMatch(s -> s.equals(role)));
        }
    
        public boolean hasRoles(final String[] acceptedRoles) {
            return stream(user.getRoleNames())
                    .get(stream -> stream.anyMatch(s1 -> stream(acceptedRoles).get(s3 -> s3.anyMatch(s2 -> s2.equals(s1)))));
        }
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Tue Aug 19 14:09:36 GMT 2025
    - 5.1K bytes
    - Click Count (0)
  9. 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());
        }
    
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Sep 17 16:01:38 GMT 2025
    - 4.4K bytes
    - Click Count (0)
  10. 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",
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 24.1K bytes
    - Click Count (0)
Back to Top