Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 101 - 110 of 990 for Streams (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. docs/es/docs/advanced/custom-response.md

    Esto sería aún más importante con streams grandes o infinitos.
    
    ///
    
    /// tip | Consejo
    
    En lugar de devolver un `StreamingResponse` directamente, probablemente deberías seguir el estilo en [Stream Data](./stream-data.md), es mucho más conveniente y maneja la cancelación por detrás de escena por ti.
    
    Si estás transmitiendo JSON Lines, sigue el tutorial [Stream JSON Lines](../tutorial/stream-json-lines.md).
    
    ///
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:15:55 GMT 2026
    - 11.6K bytes
    - Click Count (0)
  2. docs/pt/docs/advanced/custom-response.md

    Isso seria ainda mais importante com streams grandes ou infinitos.
    
    ///
    
    /// tip | Dica
    
    Em vez de retornar uma `StreamingResponse` diretamente, você deveria provavelmente seguir o estilo em [Transmitir Dados](./stream-data.md), é muito mais conveniente e lida com cancelamento nos bastidores para você.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:20:43 GMT 2026
    - 12K bytes
    - Click Count (0)
  3. internal/grid/manager.go

    	if debugPrint {
    		fmt.Println("RegisterStreamingHandler: subroute:", h.Subroute)
    	}
    	if h.Subroute == "" {
    		if m.handlers.hasAny(id) && !id.isTestHandler() {
    			return ErrHandlerAlreadyExists
    		}
    		m.handlers.streams[id] = &h
    		return nil
    	}
    	subID := makeSubHandlerID(id, h.Subroute)
    	if m.handlers.hasSubhandler(subID) && !id.isTestHandler() {
    		return ErrHandlerAlreadyExists
    	}
    	m.handlers.subStreams[subID] = &h
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Nov 12 20:41:41 GMT 2024
    - 10.8K bytes
    - Click Count (0)
  4. cmd/xl-storage-format-v2.go

    				merged = append(merged, latest)
    
    				// Calculate latest 'n' non-free versions.
    				if !latest.header.FreeVersion() {
    					nVersions++
    				}
    			}
    		}
    
    		// Remove from all streams up until latest modtime or if selected.
    		for i, vers := range versions {
    			for _, ver := range vers {
    				// Truncate later modtimes, not selected.
    				if ver.header.ModTime > latest.header.ModTime {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 65.6K bytes
    - Click Count (1)
  5. guava/src/com/google/common/collect/Sets.java

                return endOfData();
              }
            };
          }
    
          @Override
          public Stream<E> stream() {
            return Stream.concat(set1.stream(), set2.stream().filter((E e) -> !set1.contains(e)));
          }
    
          @Override
          public Stream<E> parallelStream() {
            return stream().parallel();
          }
    
          @Override
          public boolean contains(@Nullable Object object) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 83K bytes
    - Click Count (0)
  6. guava/src/com/google/common/collect/Multimaps.java

            private void writeObject(ObjectOutputStream stream) throws IOException {
          stream.defaultWriteObject();
          stream.writeObject(factory);
          stream.writeObject(backingMap());
        }
    
        @GwtIncompatible
        @J2ktIncompatible
            @SuppressWarnings("unchecked") // reading data stored by writeObject
        private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 86.3K bytes
    - Click Count (0)
  7. CHANGELOG/CHANGELOG-1.10.md

    * Get public IP for Azure vmss nodes. ([#68498](https://github.com/kubernetes/kubernetes/pull/68498), [@feiskyer](https://github.com/feiskyer))
    * adjusted http/2 buffer sizes for apiservers to prevent starvation issues between concurrent streams ([#67902](https://github.com/kubernetes/kubernetes/pull/67902), [@liggitt](https://github.com/liggitt))
    Created: Fri Apr 03 09:05:14 GMT 2026
    - Last Modified: Thu May 05 13:44:43 GMT 2022
    - 341.8K bytes
    - Click Count (0)
  8. 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.
    Created: Fri Apr 03 09:05:14 GMT 2026
    - Last Modified: Thu Feb 26 23:58:21 GMT 2026
    - 470.5K bytes
    - Click Count (0)
  9. CHANGELOG/CHANGELOG-1.3.md

    * GCI: Update the command to get the image ([#24987](https://github.com/kubernetes/kubernetes/pull/24987), [@andyzheng0831](https://github.com/andyzheng0831))
    * Port-forward: use out and error streams instead of glog ([#17030](https://github.com/kubernetes/kubernetes/pull/17030), [@csrwng](https://github.com/csrwng))
    Created: Fri Apr 03 09:05:14 GMT 2026
    - Last Modified: Thu Dec 24 02:28:26 GMT 2020
    - 84K bytes
    - Click Count (0)
  10. guava/src/com/google/common/base/Splitter.java

        return StreamSupport.stream(split(sequence).spliterator(), false);
      }
    
      /**
       * Returns a {@code MapSplitter} which splits entries based on this splitter, and splits entries
       * into keys and values using the specified separator.
       *
       * @since 10.0
       */
      public MapSplitter withKeyValueSeparator(String separator) {
        return withKeyValueSeparator(on(separator));
      }
    
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 23.8K bytes
    - Click Count (0)
Back to Top