- Sort Score
- Result 10 results
- Languages All
Results 321 - 330 of 850 for Stream (0.03 sec)
-
src/main/java/org/codelibs/fess/helper/PluginHelper.java
* * @return an array of repository URLs */ protected String[] getRepositories() { return split(ComponentUtil.getFessConfig().getPluginRepositories(), ",") .get(stream -> stream.map(String::trim).toArray(n -> new String[n])); } /** * Loads artifacts from a YAML-based repository. * * @param url the URL of the YAML repositoryRegistered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 24.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/primitives/ImmutableIntArrayTest.java
assertThat(count.get()).isEqualTo(4); } public void testStream() { ImmutableIntArray.of().stream().forEach(i -> fail()); ImmutableIntArray.of(0, 1, 3).subArray(1, 1).stream().forEach(i -> fail()); assertThat(ImmutableIntArray.of(0, 1, 3).stream().toArray()).isEqualTo(new int[] {0, 1, 3}); } public void testSubArray() { ImmutableIntArray iia0 = ImmutableIntArray.of();
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 20.2K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/rdma/RdmaProviderFactory.java
List<RdmaProvider> allProviders = Arrays.asList(new DisniRdmaProvider(), new TcpRdmaProvider()); return allProviders.stream() .filter(RdmaProvider::isAvailable) .map(RdmaProvider::getProviderName) .collect(java.util.stream.Collectors.toList()); }
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 24 00:12:28 UTC 2025 - 4.2K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/client/smb/SmbClientTest.java
} try { smbClient.doGet(baseUrl); fail(); } catch (final ChildUrlsException e) { String[] urls = e.getChildUrlList().stream().map(r -> r.getUrl()).sorted().toArray(String[]::new); assertEquals(3, urls.length); assertEquals(baseUrl + "dir1/", urls[0]); assertEquals(baseUrl + "dir3/", urls[1]);Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sat Sep 06 04:15:37 UTC 2025 - 13.7K bytes - Viewed (0) -
src/test/java/jcifs/smb1/UniAddressTest.java
import static org.junit.jupiter.api.Assertions.assertTrue; import static org.mockito.Mockito.mock; import static org.mockito.Mockito.when; import java.net.InetAddress; import java.net.UnknownHostException; import java.util.stream.Stream; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.extension.ExtendWith; import org.junit.jupiter.params.ParameterizedTest; import org.junit.jupiter.params.provider.Arguments;
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 7.9K bytes - Viewed (0) -
src/test/java/jcifs/smb/SmbRenewableCredentialsTest.java
import static org.mockito.Mockito.verify; import static org.mockito.Mockito.verifyNoMoreInteractions; import static org.mockito.Mockito.when; import java.util.function.Supplier; import java.util.stream.Stream; import javax.security.auth.Subject; import org.junit.jupiter.api.DisplayName; 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 - 7K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/util/ThreadDumpUtilTest.java
// Verify format - should contain "Thread:" entries boolean hasThreadEntry = capturedOutput.stream().anyMatch(line -> line.startsWith("Thread:")); assertTrue("Should contain Thread: entries", hasThreadEntry); // Verify format - should contain stack trace entries boolean hasStackTrace = capturedOutput.stream().anyMatch(line -> line.startsWith("\tat "));Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Jul 12 07:34:10 UTC 2025 - 15.5K bytes - Viewed (0) -
src/test/java/jcifs/smb/SmbEnumerationUtilTest.java
import java.lang.reflect.Constructor; import java.lang.reflect.InvocationTargetException; import java.lang.reflect.Method; import java.net.URL; import java.net.UnknownHostException; import java.util.stream.Stream; 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; 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 - 17.1K bytes - Viewed (0) -
android/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: Sat Aug 09 01:14:59 UTC 2025 - 35.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/entity/FacetQueryView.java
*/ @PostConstruct public void init() { final String filetypeField = ComponentUtil.getFessConfig().getIndexFieldFiletype(); final Collection<String> values = queryMap.values(); if (values.stream().anyMatch(s -> s.startsWith(filetypeField))) { final ResourceBundle resources = ResourceBundle.getBundle("fess_label", Locale.ENGLISH); final String[] fileTypes = ComponentUtil.getFileTypeHelper().getTypes();Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 4.4K bytes - Viewed (0)