- Sort Score
- Result 10 results
- Languages All
Results 791 - 800 of 835 for streams (0.11 sec)
-
android/guava/src/com/google/common/collect/Synchronized.java
@GwtIncompatible // java.io.ObjectOutputStream @J2ktIncompatible private void writeObject(ObjectOutputStream stream) throws IOException { synchronized (mutex) { stream.defaultWriteObject(); } } @GwtIncompatible // not needed in emulated source @J2ktIncompatible private static final long serialVersionUID = 0; }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 30 16:15:19 UTC 2024 - 53.4K bytes - Viewed (0) -
fess-crawler-lasta/src/main/resources/crawler/extractor.xml
"application/news-groupinfo", "application/news-transmission", "application/nss", "application/ocsp-request", "application/ocsp-response", "application/octet-stream", "application/oda", "application/oebps-package+xml", "application/ogg", "application/kate", "application/onenote", "application/parityfec", "application/patch-ops-error+xml",
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Sat Aug 01 21:40:30 UTC 2020 - 49K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/RateLimiter.java
* for (Runnable task : tasks) { * rateLimiter.acquire(); // may wait * executor.execute(task); * } * } * }</pre> * * <p>As another example, imagine that we produce a stream of data, and we want to cap it at 5kb per * second. This could be accomplished by requiring a permit per byte, and specifying a rate of 5000 * permits per second: * * <pre>{@code
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:51:36 UTC 2024 - 21.9K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb1/ServerMessageBlock.java
* actually purer. However, in the case of smb we know the * wordCount and byteCount. And since every subclass of * ServerMessageBlock would have to perform the same read * operation on the input stream, we might as will pull that * common functionality into the superclass and read wordCount * and byteCount worth of data. * * We will still use the readXxxWireFormat return values to
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Aug 05 09:45:59 UTC 2018 - 32.7K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/RateLimiter.java
* for (Runnable task : tasks) { * rateLimiter.acquire(); // may wait * executor.execute(task); * } * } * }</pre> * * <p>As another example, imagine that we produce a stream of data, and we want to cap it at 5kb per * second. This could be accomplished by requiring a permit per byte, and specifying a rate of 5000 * permits per second: * * <pre>{@code
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:51:36 UTC 2024 - 21.6K bytes - Viewed (0) -
guava/src/com/google/common/collect/ImmutableSortedSet.java
import java.util.Iterator; import java.util.NavigableSet; import java.util.SortedSet; import java.util.Spliterator; import java.util.Spliterators; import java.util.function.Consumer; import java.util.stream.Collector; import javax.annotation.CheckForNull; import org.checkerframework.checker.nullness.qual.Nullable; /** * A {@link NavigableSet} whose contents will never change, with many other important properties
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 30 16:15:19 UTC 2024 - 39.1K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ImmutableMultimap.java
@Override Object writeReplace() { return new KeysSerializedForm(ImmutableMultimap.this); } @GwtIncompatible @J2ktIncompatible private void readObject(ObjectInputStream stream) throws InvalidObjectException { throw new InvalidObjectException("Use KeysSerializedForm"); } } @GwtIncompatible @J2ktIncompatible
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 30 16:15:19 UTC 2024 - 27.9K bytes - Viewed (0) -
src/archive/zip/reader_test.go
Mode: 0666, }, }, }, // Tests that we verify (and accept valid) crc32s on files // with crc32s in their file header (not in data descriptors) { Name: "crc32-not-streamed.zip", File: []ZipTestFile{ { Name: "foo.txt", Content: []byte("foo\n"), Modified: time.Date(2012, 3, 8, 16, 59, 10, 0, timeZone(-8*time.Hour)), Mode: 0644, }, {
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Thu Jul 25 00:25:45 UTC 2024 - 55.6K bytes - Viewed (0) -
guava/src/com/google/common/net/MediaType.java
* @since 20.0 */ public static final MediaType NACL_PORTABLE_APPLICATION = createConstant(APPLICATION_TYPE, "x-pnacl"); public static final MediaType OCTET_STREAM = createConstant(APPLICATION_TYPE, "octet-stream"); public static final MediaType OGG_CONTAINER = createConstant(APPLICATION_TYPE, "ogg"); public static final MediaType OOXML_DOCUMENT = createConstant(
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Sep 26 19:15:09 UTC 2024 - 47.5K bytes - Viewed (0) -
fess-crawler/src/main/resources/org/codelibs/fess/crawler/mime/tika-mimetypes.xml
<mime-type type="application/nss"/> <mime-type type="application/ocsp-request"/> <mime-type type="application/ocsp-response"/> <mime-type type="application/octet-stream"> <magic priority="50"> <match value="#\ This\ is\ a\ shell\ archive" type="string" offset="10"/> <match value="\037\036" type="string" offset="0"/> <match value="017437" type="host16" offset="0"/>
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Sep 21 06:46:43 UTC 2023 - 298.5K bytes - Viewed (0)