- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 819 for straum (0.21 sec)
-
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/admin/elevateword/AdminElevatewordAction.java
BeanUtil.copyBeanToBean(form, entity, op -> op.exclude(Stream .concat(Stream.of(Constants.COMMON_CONVERSION_RULE), Stream.of(Constants.PERMISSIONS)).toArray(n -> new String[n]))); final PermissionHelper permissionHelper = ComponentUtil.getPermissionHelper(); entity.setPermissions(split(form.permissions, "\n").get(
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 18.7K bytes - Viewed (0) -
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) -
docs/debugging/inspect/decrypt-v2.go
} if extracted { return keepFileErr{fmt.Errorf("next stream: %w", err)} } return fmt.Errorf("next stream: %w", err) } if stream.Name == "inspect.zip" { if extracted { return keepFileErr{errors.New("multiple inspect.zip streams found")} } _, err := io.Copy(w, stream) if err != nil { return fmt.Errorf("reading inspect stream: %w", err) } fmt.Println(okMsg) extracted = true
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 11 21:22:47 GMT 2024 - 2.2K 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) -
android/guava/src/com/google/common/io/ByteStreams.java
/** * Copies all bytes from the input stream to the output stream. Does not close or flush either * stream. * * <p><b>Java 9 users and later:</b> this method should be treated as deprecated; use the * equivalent {@link InputStream#transferTo} method instead. * * @param from the input stream to read from * @param to the output stream to write to * @return the number of bytes copied
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Jan 17 18:59:58 GMT 2024 - 29.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/SuggestHelper.java
split(fessConfig.getSuggestFieldContents(), ",") .of(stream -> stream.filter(StringUtil::isNotBlank).forEach(contentFieldNameSet::add)); split(fessConfig.getSuggestFieldTags(), ",").of(stream -> stream.filter(StringUtil::isNotBlank).forEach(tagFieldNameSet::add)); split(fessConfig.getSuggestFieldRoles(), ",").of(stream -> stream.filter(StringUtil::isNotBlank).forEach(roleFieldNameSet::add));
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 18K bytes - Viewed (0) -
api/maven-api-model/src/main/java/org/apache/maven/api/model/InputSource.java
@Override public int hashCode() { return Objects.hash(modelId, location, inputs); } Stream<InputSource> sources() { return inputs != null ? inputs.stream() : Stream.of(this); } @Override public String toString() { if (inputs != null) { return inputs.stream().map(InputSource::toString).collect(Collectors.joining(", ", "merged[", "]")); }
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Tue Sep 05 16:06:44 GMT 2023 - 3K 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) -
mockwebserver/src/main/kotlin/mockwebserver3/internal/duplex/MockStreamHandler.kt
val task = serviceStreamTask(stream) results.add(task) task.run() } /** Returns a task that processes both request and response from [stream]. */ private fun serviceStreamTask(stream: Stream): FutureTask<Void> { return FutureTask<Void> { stream.requestBody.use { stream.responseBody.use { while (true) { val action = actions.poll() ?: break
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.2K bytes - Viewed (0)