- Sort Score
- Result 10 results
- Languages All
Results 951 - 960 of 1,027 for jstream (0.06 sec)
-
internal/config/notify/help.go
Description: "client cert key for NATS mTLS auth", Optional: true, Type: "string", Sensitive: true, }, config.HelpKV{ Key: target.NATSJetStream, Description: "enable JetStream support", Optional: true, Type: "on|off", }, config.HelpKV{ Key: target.NATSQueueDir, Description: queueDirComment, Optional: true, Type: "path",
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 19.2K bytes - Viewed (0) -
cmd/generic-handlers.go
return } else if rec != nil { stack := debug.Stack() logger.Error("panic: \"%s %s\": %v\n%s", r.Method, r.URL, rec, string(stack)) // Try to write an error response, upstream may not have written header. writeErrorResponse(r.Context(), w, errorCodes.ToAPIErr(ErrInternalError), r.URL) return } }() h.ServeHTTP(w, r) }) }Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 20.7K bytes - Viewed (1) -
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 @J2ktIncompatibleRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Dec 09 15:58:48 UTC 2025 - 27.1K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Cache.kt
private val responseHeaders: Headers private val handshake: Handshake? private val sentRequestMillis: Long private val receivedResponseMillis: Long /** * Reads an entry from an input stream. A typical entry looks like this: * * ``` * http://google.com/foo * GET * 2 * Accept-Language: fr-CA * Accept-Charset: UTF-8 * HTTP/1.1 200 OK * 3Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Fri Oct 03 17:41:45 UTC 2025 - 26.8K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Maps.java
* * <p><b>Note:</b> on Java 8+, it is usually better to use streams. For example: * * {@snippet : * import static com.google.common.collect.ImmutableMap.toImmutableMap; * ... * ImmutableMap<Color, String> colorNames = * allColors.stream().collect(toImmutableMap(c -> c, c -> c.toString())); * } *Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Sep 23 17:50:58 UTC 2025 - 157.6K bytes - Viewed (0) -
guava/src/com/google/common/collect/Maps.java
* * <p><b>Note:</b> on Java 8+, it is usually better to use streams. For example: * * {@snippet : * import static com.google.common.collect.ImmutableMap.toImmutableMap; * ... * ImmutableMap<Color, String> colorNames = * allColors.stream().collect(toImmutableMap(c -> c, c -> c.toString())); * } *Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Nov 17 22:50:48 UTC 2025 - 163.5K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java
final List<T> bufferedList = new ArrayList<>(bulkBufferSize); final StringBuilder failureBuf = new StringBuilder(100); list.stream().forEach(target -> { bufferedList.add(target); if (bufferedList.size() >= bulkBufferSize) { final BulkResponse response = doInsertAll(bufferedList, opType);
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Nov 20 08:40:57 UTC 2025 - 34.3K bytes - Viewed (0) -
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 @J2ktIncompatibleRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Dec 09 15:58:48 UTC 2025 - 28.1K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.32.md
- Added a `Stream` field to `PodLogOptions`, which allows clients to request certain log stream (stdout or stderr) of the container.
Registered: Fri Dec 26 09:05:12 UTC 2025 - Last Modified: Tue Dec 16 18:27:41 UTC 2025 - 448.1K 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: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Oct 16 07:46:32 UTC 2025 - 320.2K bytes - Viewed (5)