Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 104 for Streaming (0.08 sec)

  1. docs/nl/docs/features.md

    * **WebSocket** ondersteuning.
    * Taken in de achtergrond tijdens het proces.
    * Opstart- en afsluit events.
    * Test client gebouwd op HTTPX.
    * **CORS**, GZip, Statische bestanden, Streaming reacties.
    * **Sessie en Cookie** ondersteuning.
    * 100% van de code is getest.
    * 100% type geannoteerde codebase.
    
    ## Pydantic functionaliteit
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Sep 03 13:50:38 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/hash/HashFunction.java

       * }</pre>
       */
      Hasher newHasher();
    
      /**
       * Begins a new hash code computation as {@link #newHasher()}, but provides a hint of the expected
       * size of the input (in bytes). This is only important for non-streaming hash functions (hash
       * functions that need to buffer their whole input before processing any of it).
       */
      Hasher newHasher(int expectedInputSize);
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue May 25 18:22:59 UTC 2021
    - 10.9K bytes
    - Viewed (0)
  3. guava/src/com/google/common/hash/HashFunction.java

       * }</pre>
       */
      Hasher newHasher();
    
      /**
       * Begins a new hash code computation as {@link #newHasher()}, but provides a hint of the expected
       * size of the input (in bytes). This is only important for non-streaming hash functions (hash
       * functions that need to buffer their whole input before processing any of it).
       */
      Hasher newHasher(int expectedInputSize);
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue May 25 18:22:59 UTC 2021
    - 10.9K bytes
    - Viewed (0)
  4. internal/grid/manager.go

    		return ErrHandlerAlreadyExists
    	}
    
    	m.handlers.stateless[id] = &h
    	return nil
    }
    */
    
    // RegisterStreamingHandler will register a stateless handler that serves
    // two-way streaming requests.
    func (m *Manager) RegisterStreamingHandler(id HandlerID, h StreamHandler) error {
    	if !id.valid() {
    		return ErrUnknownHandler
    	}
    	if debugPrint {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  5. okhttp-logging-interceptor/src/test/java/okhttp3/logging/HttpLoggingInterceptorTest.kt

          .assertLogMatch(Regex("""<-- 200 OK $url \(\d+ms\)"""))
          .assertLogEqual("Content-Type: text/event-stream")
          .assertLogMatch(Regex("""Transfer-encoding: chunked"""))
          .assertLogEqual("<-- END HTTP (streaming)")
          .assertNoMoreLogs()
        applicationLogs
          .assertLogEqual("--> GET $url")
          .assertLogEqual("--> END GET")
          .assertLogMatch(Regex("""<-- 200 OK $url \(\d+ms\)"""))
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 06 09:14:38 UTC 2024
    - 37.6K bytes
    - Viewed (0)
  6. cmd/metacache-stream.go

    type metacacheBlockWriter struct {
    	wg           sync.WaitGroup
    	streamErr    error
    	blockEntries int
    }
    
    // newMetacacheBlockWriter provides a streaming block writer.
    // Each block is the size of the capacity of the input channel.
    // The caller should close to indicate the stream has ended.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 19.5K bytes
    - Viewed (0)
  7. internal/s3select/jstream/decoder.go

    // containing those values is emitted.
    func (d *Decoder) Recursive() *Decoder {
    	d.emitRecursive = true
    	return d
    }
    
    // Stream begins decoding from the underlying reader and returns a
    // streaming MetaValue channel for JSON values at the configured emitDepth.
    func (d *Decoder) Stream() chan *MetaValue {
    	go d.decode()
    	return d.metaCh
    }
    
    // Pos returns the number of bytes consumed from the underlying reader
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  8. CHANGELOG/CHANGELOG-1.32.md

      To request this behaviour, your client software must enable the `WatchListClient` client-go feature gate. Additionally, streaming is only available if supported by the cluster; the API server that you connect to must also support streaming.
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Tue Oct 29 20:17:52 UTC 2024
    - 121.6K bytes
    - Viewed (0)
  9. docs/vi/docs/features.md

    * Hỗ trợ **WebSocket**.
    * In-process background tasks.
    * Startup and shutdown events.
    * Client cho kiểm thử xây dựng trên HTTPX.
    * **CORS**, GZip, Static Files, Streaming responses.
    * Hỗ trợ **Session and Cookie**.
    * 100% test coverage.
    * 100% type annotated codebase.
    
    ## Tính năng của Pydantic
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  10. cmd/metacache-server-pool.go

    			} else {
    				// Continue listing
    				o.ID = c.id
    				go c.keepAlive(ctx, rpc)
    			}
    		}
    	}
    
    	if o.ID != "" && !o.Transient {
    		// We have an existing list ID, continue streaming.
    		if o.Create {
    			o.debugln("Creating", o)
    			entries, err = z.listAndSave(ctx, o)
    			if err == nil || err == io.EOF {
    				return entries, err
    			}
    			entries.truncate(0)
    		} else {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 12.7K bytes
    - Viewed (0)
Back to top