- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 227 for Streams (0.17 sec)
-
src/main/java/jcifs/smb1/smb1/SmbFileInputStream.java
response.off += n; } while( len > 0 && n == r ); return (int)(fp - start); } /** * This stream class is unbuffered. Therefore this method will always * return 0 for streams connected to regular files. However, a * stream created from a Named Pipe this method will query the server using a * "peek named pipe" operation and return the number of available bytes * on the server. */
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Fri Mar 22 21:10:40 GMT 2019 - 7.9K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbFileInputStream.java
// reads return (int) ( this.fp - start ); } } /** * This stream class is unbuffered. Therefore this method will always * return 0 for streams connected to regular files. However, a * stream created from a Named Pipe this method will query the server using a * "peek named pipe" operation and return the number of available bytes
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Sun May 17 08:55:14 GMT 2020 - 13.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/sso/aad/AzureAdAuthenticator.java
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 28.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/dataconfig/AdminDataconfigAction.java
*/ package org.codelibs.fess.app.web.admin.dataconfig; import static org.codelibs.core.stream.StreamUtil.split; import static org.codelibs.core.stream.StreamUtil.stream; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.stream.Collectors; import java.util.stream.Stream; import javax.annotation.Resource; import org.apache.logging.log4j.LogManager;
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 17.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/webconfig/AdminWebconfigAction.java
* governing permissions and limitations under the License. */ package org.codelibs.fess.app.web.admin.webconfig; import static org.codelibs.core.stream.StreamUtil.split; import static org.codelibs.core.stream.StreamUtil.stream; import java.util.stream.Collectors; import java.util.stream.Stream; import javax.annotation.Resource; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger;
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 17.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/user/exentity/User.java
asDocMeta().id(id); } @Override public String[] getRoleNames() { return stream(getRoles()).get(stream -> stream.map(this::decode).toArray(n -> new String[n])); } @Override public String[] getGroupNames() { return stream(getGroups()).get(stream -> stream.map(this::decode).toArray(n -> new String[n])); } private String decode(final String value) {
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 3.8K bytes - Viewed (1) -
src/main/java/org/codelibs/fess/app/web/base/login/OpenIdConnectCredential.java
final Set<String> permissionSet = new HashSet<>(); permissionSet.add(systemHelper.getSearchRoleByUser(name)); stream(groups).of(stream -> stream.forEach(s -> permissionSet.add(systemHelper.getSearchRoleByGroup(s)))); stream(roles).of(stream -> stream.forEach(s -> permissionSet.add(systemHelper.getSearchRoleByRole(s)))); permissions = permissionSet.toArray(new String[permissionSet.size()]);
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 4.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/auth/AuthenticationManager.java
public void insert(final User user) { chains().of(stream -> stream.forEach(c -> c.update(user))); } public boolean changePassword(final String username, final String password) { return chains().get(stream -> stream.allMatch(c -> c.changePassword(username, password))); } public void delete(final User user) { chains().of(stream -> stream.forEach(c -> c.delete(user))); }
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 1.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/query/PhraseQueryCommand.java
context.addFieldLog(field, text); stream(texts).of(stream -> stream.forEach(t -> context.addHighlightedQuery(t))); return buildDefaultQueryBuilder(fessConfig, context, (f, b) -> buildMatchPhraseQuery(f, text).boost(b * boost)); } if (isSearchField(field)) { context.addFieldLog(field, text); stream(texts).of(stream -> stream.forEach(t -> context.addHighlightedQuery(t)));
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 3.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/ActivityHelper.java
*/ package org.codelibs.fess.helper; import static org.codelibs.core.stream.StreamUtil.stream; import java.time.ZonedDateTime; import java.time.format.DateTimeFormatter; import java.util.Comparator; import java.util.LinkedHashMap; import java.util.Locale; import java.util.Map; import java.util.stream.Collectors; import javax.annotation.PostConstruct;
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 7.7K bytes - Viewed (0)