Search Options

Results per page
Sort
Preferred Languages
Advance

Results 221 - 230 of 258 for consumers (1.04 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. guava-testlib/test/com/google/common/testing/NullPointerTesterTest.java

        }
      }
    
      public void testNullBounds() {
        // NullBounds has methods whose parameters are type variables that have
        // "extends @Nullable Object" as a bound. This test ensures that NullPointerTester considers
        // those parameters to be @Nullable, so it won't call the methods.
        NullBounds<?, ?, ?> nullBounds = new NullBounds<>();
        new NullPointerTester().testAllPublicInstanceMethods(nullBounds);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Jul 14 14:44:08 UTC 2025
    - 47.7K bytes
    - Viewed (0)
  6. 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)
  7. tensorflow/c/c_api_test.cc

      EXPECT_EQ(attr_value.i(), 2);
    
      // Placeholder oper now has a consumer.
      ASSERT_EQ(1, TF_OperationOutputNumConsumers(TF_Output{feed, 0}));
      TF_Input feed_port;
      EXPECT_EQ(1, TF_OperationOutputConsumers(TF_Output{feed, 0}, &feed_port, 1));
      EXPECT_EQ(add, feed_port.oper);
      EXPECT_EQ(0, feed_port.index);
    
      // The scalar const oper also has a consumer.
      ASSERT_EQ(1, TF_OperationOutputNumConsumers(TF_Output{three, 0}));
    Registered: Tue Sep 09 12:39:10 UTC 2025
    - Last Modified: Fri Dec 27 12:18:10 UTC 2024
    - 97K bytes
    - Viewed (0)
  8. cmd/bucket-replication.go

    	return saveConfig(ctx, objectAPI, configFile, buf)
    }
    
    // getReplicationDiff returns un-replicated objects in a channel.
    // If a non-nil channel is returned it must be consumed fully or
    // the provided context must be canceled.
    func getReplicationDiff(ctx context.Context, objAPI ObjectLayer, bucket string, opts madmin.ReplDiffOpts) (chan madmin.DiffInfo, error) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/collect/Iterables.java

       * @return a view of the supplied iterable that wraps each generated iterator through {@link
       *     Iterators#consumingIterator(Iterator)}; for queues, an iterable that generates iterators
       *     that return and consume the queue's elements in queue order
       * @see Iterators#consumingIterator(Iterator)
       * @since 2.0
       */
      public static <T extends @Nullable Object> Iterable<T> consumingIterable(Iterable<T> iterable) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 43.6K bytes
    - Viewed (0)
  10. docs/es/docs/async.md

    * una operación de API remota
    * que una operación de base de datos termine
    * que una query de base de datos devuelva los resultados
    * etc.
    
    Como el tiempo de ejecución se consume principalmente esperando operaciones de <abbr title="Input and Output">I/O</abbr>, las llaman operaciones "I/O bound".
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 09:56:21 UTC 2025
    - 24.7K bytes
    - Viewed (0)
Back to top