Search Options

Results per page
Sort
Preferred Languages
Advance

Results 211 - 220 of 251 for Consumer (0.06 sec)

  1. src/bytes/buffer.go

    }
    
    // ReadRune reads and returns the next UTF-8-encoded
    // Unicode code point from the buffer.
    // If no bytes are available, the error returned is io.EOF.
    // If the bytes are an erroneous UTF-8 encoding, it
    // consumes one byte and returns U+FFFD, 1.
    func (b *Buffer) ReadRune() (r rune, size int, err error) {
    	if b.empty() {
    		// Buffer is empty, reset to recover space.
    		b.Reset()
    		return 0, 0, io.EOF
    	}
    	c := b.buf[b.off]
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Mon May 19 17:38:56 UTC 2025
    - 16K bytes
    - Viewed (0)
  2. RELEASE.md

            SavedModel.
        *   The user object metadata field in the SavedModel proto has been
            deprecated as part of the updates to Keras SavedModel. Keras was the
            only consumer of this field prior to the update.
    *   GPU
        *   TF 2.3 includes PTX kernels only for
            [compute capability](https://developer.nvidia.com/cuda-gpus) 7.0 to
    Registered: Tue Sep 09 12:39:10 UTC 2025
    - Last Modified: Mon Aug 18 20:54:38 UTC 2025
    - 740K bytes
    - Viewed (2)
  3. tensorflow/c/c_api.cc

      }
      return count;
    }
    
    int TF_OperationOutputConsumers(TF_Output oper_out, TF_Input* consumers,
                                    int max_consumers) {
      int count = 0;
      for (const auto* edge : oper_out.oper->node.out_edges()) {
        if (edge->src_output() == oper_out.index) {
          if (count < max_consumers) {
            consumers[count] = {ToOperation(edge->dst()), edge->dst_input()};
          }
          ++count;
        }
    Registered: Tue Sep 09 12:39:10 UTC 2025
    - Last Modified: Tue May 13 06:30:43 UTC 2025
    - 102.3K bytes
    - Viewed (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt

      /**
       * Settings we receive from the peer. Changes to the field are guarded by this. The instance is
       * never mutated once it has been assigned.
       */
      var peerSettings = DEFAULT_SETTINGS
    
      /** The bytes consumed and acknowledged by the application. */
      val readBytes: WindowCounter = WindowCounter(streamId = 0)
    
      /** The total number of bytes produced by the application. */
      var writeBytesTotal = 0L
        private set
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 31.8K bytes
    - Viewed (0)
  5. docs/en/docs/async.md

    * the contents your program gave to the system to be written to disk
    * a remote API operation
    * a database operation to finish
    * a database query to return the results
    * etc.
    
    As the execution time is consumed mostly by waiting for <abbr title="Input and Output">I/O</abbr> operations, they call them "I/O bound" operations.
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 09:56:21 UTC 2025
    - 24K bytes
    - Viewed (0)
  6. docs/es/docs/deployment/docker.md

    De esta forma, los contenedores consumen **pocos recursos**, una cantidad comparable a ejecutar los procesos directamente (una máquina virtual consumiría mucho más).
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Fri May 30 13:15:52 UTC 2025
    - 31K bytes
    - Viewed (0)
  7. src/bufio/bufio_test.go

    type eofReader struct {
    	buf []byte
    }
    
    func (r *eofReader) Read(p []byte) (int, error) {
    	read := copy(p, r.buf)
    	r.buf = r.buf[read:]
    
    	switch read {
    	case 0, len(r.buf):
    		// As allowed in the documentation, this will return io.EOF
    		// in the same call that consumes the last of the data.
    		// https://godoc.org/io#Reader
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Fri Feb 07 01:08:54 UTC 2025
    - 51.6K bytes
    - Viewed (0)
  8. docs/changelogs/changelog_3x.md

        now be sufficient to break out an in-flight OkHttp call.
     *  Fix: Don't drop a call to `EventListener.callEnd()` when the response body is consumed inside an
        interceptor.
    
    
    ## Version 3.10.0
    
    _2018-02-24_
    
     *  **The pingInterval() feature now aggressively checks connectivity for web
        sockets and HTTP/2 connections.**
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sun Feb 06 14:55:54 UTC 2022
    - 50.8K bytes
    - Viewed (0)
  9. docs/en/docs/release-notes.md

    * Clarify function name in example in docs. PR [#1121](https://github.com/tiangolo/fastapi/pull/1121) by [@tmsick](https://github.com/tmsick).
    * Add external link [Apache Kafka producer and consumer with FastAPI and aiokafka](https://iwpnd.pw/articles/2020-03/apache-kafka-fastapi-geostream) to docs. PR [#1112](https://github.com/tiangolo/fastapi/pull/1112) by [@iwpnd](https://github.com/iwpnd).
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Fri Sep 05 12:48:45 UTC 2025
    - 544.1K bytes
    - Viewed (0)
  10. src/bufio/bufio.go

    	b.lastByte = -1
    	b.lastRuneSize = -1
    	return nil
    }
    
    // ReadRune reads a single UTF-8 encoded Unicode character and returns the
    // rune and its size in bytes. If the encoded rune is invalid, it consumes one byte
    // and returns unicode.ReplacementChar (U+FFFD) with a size of 1.
    func (b *Reader) ReadRune() (r rune, size int, err error) {
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Wed Sep 03 14:04:47 UTC 2025
    - 22K bytes
    - Viewed (0)
Back to top