- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 761 for straum (0.16 sec)
-
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
peer.acceptFrame() // SYN_STREAM on stream 1 for (i in 0 until framesThatFillWindow) { peer.acceptFrame() // DATA on stream 1 } peer.acceptFrame() // SYN_STREAM on stream 2 peer.acceptFrame() // DATA on stream 2 peer.play() // Play it back. val connection = connect(peer) val stream1 = connection.newStream(headerEntries("a", "apple"), true)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 75.4K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/FluentIterable.java
* elements. * * <p><b>{@code Stream} equivalent:</b> if the source iterable has only a single element {@code * e}, use {@code Stream.generate(() -> e)}. Otherwise, collect your stream into a collection and * use {@code Stream.generate(() -> collection).flatMap(Collection::stream)}. */ public final FluentIterable<E> cycle() { return from(Iterables.cycle(getDelegate()));
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Jan 30 00:14:39 GMT 2024 - 35.7K bytes - Viewed (0) -
guava/src/com/google/common/collect/Iterables.java
* * <p><b>Java 8+ users:</b> If passing a single element {@code e}, the {@code Stream} equivalent * of this method is {@code Stream.generate(() -> e)}. Otherwise, put the elements in a collection * and use {@code Stream.generate(() -> collection).flatMap(Collection::stream)}. */ @SafeVarargs public static <T extends @Nullable Object> Iterable<T> cycle(T... elements) {
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Thu Feb 15 16:12:13 GMT 2024 - 42.5K bytes - Viewed (0) -
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 May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 18.7K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Serialization.java
Map<K, V> map, ObjectOutputStream stream) throws IOException { stream.writeInt(map.size()); for (Map.Entry<K, V> entry : map.entrySet()) { stream.writeObject(entry.getKey()); stream.writeObject(entry.getValue()); } } /** * Populates a map by reading an input stream, as part of deserialization. See {@link #writeMap} * for the data format. */
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Mar 06 16:06:58 GMT 2023 - 8.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/ldap/LdapManager.java
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 65.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2ExchangeCodec.kt
if (canceled) { stream!!.closeLater(ErrorCode.CANCEL) throw IOException("Canceled") } stream!!.readTimeout().timeout(chain.readTimeoutMillis.toLong(), TimeUnit.MILLISECONDS) stream!!.writeTimeout().timeout(chain.writeTimeoutMillis.toLong(), TimeUnit.MILLISECONDS) } override fun flushRequest() { http2Connection.flush() } override fun finishRequest() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/FrameLogTest.kt
assertThat(formattedFlags).containsExactly( "", "END_STREAM", "00000010", "00000011", "END_HEADERS", "END_STREAM|END_HEADERS", "00000110", "00000111", "PADDED", "END_STREAM|PADDED", "00001010", "00001011", "00001100", "END_STREAM|END_HEADERS|PADDED", "00001110", "00001111", "00010000",
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.9K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/ExtensibleEnumRegistries.java
protected final Map<String, T> values; DefaultExtensibleEnumRegistry(List<P> providers, T... builtinValues) { values = Stream.<T>concat( Stream.of(builtinValues), providers.stream().flatMap(p -> p.provides().stream())) .collect(Collectors.toUnmodifiableMap(t -> t.id().toLowerCase(Locale.ROOT), t -> t)); } @Override
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Fri Apr 12 10:50:18 GMT 2024 - 3.8K bytes - Viewed (0) -
mockwebserver/src/test/java/mockwebserver3/internal/http2/Http2Server.kt
if (file.isDirectory) { serveDirectory(stream, file.listFiles()!!) } else if (file.exists()) { serveFile(stream, file) } else { send404(stream, path) } } catch (e: IOException) { Platform.get().log("Failure serving Http2Stream: " + e.message, Platform.INFO, null) } } private fun send404( stream: Http2Stream, path: String, ) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.1K bytes - Viewed (0)