- Sort Score
- Result 10 results
- Languages All
Results 301 - 310 of 771 for Streams (0.72 sec)
-
src/main/java/org/codelibs/fess/helper/VirtualHostHelper.java
* Gets all configured virtual host paths. * * @return An array of virtual host paths */ public String[] getVirtualHostPaths() { return stream(ComponentUtil.getFessConfig().getVirtualHosts()) .get(stream -> stream.map(h -> "/" + h.getValue3()).toArray(n -> new String[n])); }
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 4.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/ThemeHelper.java
import java.nio.file.StandardCopyOption; import java.util.Comparator; import java.util.stream.Stream; import java.util.zip.ZipEntry; import java.util.zip.ZipInputStream; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.core.lang.StringUtil; import org.codelibs.core.stream.StreamUtil; import org.codelibs.fess.exception.ThemeException;
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 7K bytes - Viewed (0) -
src/test/java/org/codelibs/curl/CurlRequestTest.java
CurlRequest request = new CurlRequest(Method.POST, "https://example.com"); InputStream stream = new ByteArrayInputStream("test data".getBytes()); CurlRequest result = request.body(stream); assertSame(request, result); // Fluent API assertNull(request.body()); // body() returns String body, not stream } @Test public void testBodyStringAfterStreamThrowsException() {
Registered: Thu Sep 04 15:34:10 UTC 2025 - Last Modified: Thu Jul 31 01:01:12 UTC 2025 - 8.8K bytes - Viewed (0) -
guava/src/com/google/common/collect/CompactHashMap.java
@J2ktIncompatible private void writeObject(ObjectOutputStream stream) throws IOException { stream.defaultWriteObject(); stream.writeInt(size()); Iterator<Entry<K, V>> entryIterator = entrySetIterator(); while (entryIterator.hasNext()) { Entry<K, V> e = entryIterator.next(); stream.writeObject(e.getKey()); stream.writeObject(e.getValue()); } }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue Jul 08 18:32:10 UTC 2025 - 39.6K bytes - Viewed (0) -
src/test/java/jcifs/smb/HandlerTest.java
import static org.mockito.Mockito.verify; import static org.mockito.Mockito.when; import java.io.IOException; import java.net.MalformedURLException; import java.net.URL; import java.net.URLConnection; 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: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 7.8K bytes - Viewed (0) -
src/test/java/jcifs/smb/SSPContextTest.java
import static org.mockito.Mockito.verify; import static org.mockito.Mockito.verifyNoMoreInteractions; import static org.mockito.Mockito.when; import java.util.Arrays; import java.util.Objects; import java.util.stream.Stream; import org.bouncycastle.asn1.ASN1ObjectIdentifier; import org.junit.jupiter.api.DisplayName; import org.junit.jupiter.api.Nested; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.extension.ExtendWith;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 15.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/dict/stopwords/StopwordsFile.java
} } /** * Reloads the stopwords dictionary from an input stream. * * @param updater An optional updater to apply changes. * @param in The input stream to read the dictionary from. * @throws DictionaryException if the input stream cannot be parsed. */ protected void reload(final StopwordsUpdater updater, final InputStream in) {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 12.6K bytes - Viewed (0) -
src/test/java/jcifs/internal/util/StringUtilTest.java
package jcifs.internal.util; import static org.junit.jupiter.api.Assertions.assertEquals; 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.params.ParameterizedTest; import org.junit.jupiter.params.provider.Arguments; import org.junit.jupiter.params.provider.MethodSource;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 07:14:38 UTC 2025 - 9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/timer/HotThreadMonitorTarget.java
* either express or implied. See the License for the specific language * governing permissions and limitations under the License. */ package org.codelibs.fess.timer; import java.util.stream.Collectors; import org.apache.commons.text.StringEscapeUtils; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.fess.Constants;
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 3.7K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/notify/Smb2ChangeNotifyRequest.java
/** * Notify when alternate data stream name changes */ public static final int FILE_NOTIFY_CHANGE_STREAM_NAME = 0x200; /** * Notify when alternate data stream size changes */ public static final int FILE_NOTIFY_CHANGE_STREAM_SIZE = 0x400; /** * Notify when alternate data stream is written */
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 5.5K bytes - Viewed (0)