Search Options

Results per page
Sort
Preferred Languages
Advance

Results 951 - 960 of 1,027 for jstream (0.06 sec)

  1. 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)
  2. 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)
  3. 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 Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Dec 09 15:58:48 UTC 2025
    - 27.1K bytes
    - Viewed (0)
  4. 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
         * 3
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Oct 03 17:41:45 UTC 2025
    - 26.8K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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 Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Dec 09 15:58:48 UTC 2025
    - 28.1K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top