Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 645 for consume (0.07 sec)

  1. api/maven-api-core/src/main/java/org/apache/maven/api/package-info.java

     * from a Project Object Model (POM).</p>
     *
     * <p><dfn>Project Object Model</dfn> or <dfn>POM</dfn> refers to the information describing
     * all the information needed to build or consume a project.  Those are usually loaded from
     * a file named {@code pom.xml} and loaded into a {@link org.apache.maven.api.model.Model Model}
     * instances.</p>
     *
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Tue Aug 27 21:13:34 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt

        timeout.setDelegate(Timeout.NONE)
        oldDelegate.clearDeadline()
        oldDelegate.clearTimeout()
      }
    
      /**
       * The response body from a CONNECT should be empty, but if it is not then we should consume it
       * before proceeding.
       */
      fun skipConnectBody(response: Response) {
        val contentLength = response.headersContentLength()
        if (contentLength == -1L) return
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/io/ByteSourceTest.java

            new ByteProcessor<@Nullable Void>() {
              boolean firstCall = true;
    
              @Override
              public boolean processBytes(byte[] buf, int off, int len) throws IOException {
                assertTrue("consume() called twice", firstCall);
                firstCall = false;
                return false;
              }
    
              @Override
              public @Nullable Void getResult() {
                return null;
              }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/io/ByteSourceTest.java

            new ByteProcessor<@Nullable Void>() {
              boolean firstCall = true;
    
              @Override
              public boolean processBytes(byte[] buf, int off, int len) throws IOException {
                assertTrue("consume() called twice", firstCall);
                firstCall = false;
                return false;
              }
    
              @Override
              public @Nullable Void getResult() {
                return null;
              }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  5. guava/src/com/google/common/io/CharSource.java

     *       block indefinitely or fail if the source creates an infinite reader.
     *   <li><b>Non-destructive:</b> A <i>destructive</i> reader will consume or otherwise alter the
     *       source as they are read from it. A source that provides such readers will not be reusable,
     *       and operations that read from the stream (including {@link #length()}, in some
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 31 14:20:11 UTC 2024
    - 25.5K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/io/ByteSource.java

     *       block indefinitely or fail if the source creates an infinite stream.
     *   <li><b>Non-destructive:</b> A <i>destructive</i> stream will consume or otherwise alter the
     *       bytes of the source as they are read from it. A source that provides such streams will not
     *       be reusable, and operations that read from the stream (including {@link #size()}, in some
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 26.2K bytes
    - Viewed (0)
  7. docs/es/docs/async.md

    * una operación relacionada con una API remota
    * una operación de base de datos
    * el retorno de resultados de una consulta de base de datos
    * etc.
    
    Como el tiempo de ejecución se consume principalmente al esperar a operaciones de <abbr title = "Input and Output">I/O</abbr>, las llaman operaciones "<abbr title="atadas a Entrada y Salida">I/O bound</abbr>".
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Mon Aug 19 18:15:21 UTC 2024
    - 24.9K bytes
    - Viewed (0)
  8. 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(
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Apr 24 19:38:27 UTC 2024
    - 42.8K bytes
    - Viewed (0)
  9. src/cmd/asm/internal/asm/parse.go

    func (p *Parser) expectOperandEnd() {
    	p.expect(scanner.EOF, "end of operand")
    }
    
    // expect verifies that the next item has the expected type. It does not consume it.
    func (p *Parser) expect(expectedToken lex.ScanToken, expectedMessage string) {
    	if p.peek() != expectedToken {
    		p.errorf("expected %s, found %s", expectedMessage, p.next())
    	}
    }
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Sep 04 18:16:59 UTC 2024
    - 36.9K bytes
    - Viewed (0)
  10. cmd/batch-handlers.go

    				if aerr == nil {
    					return
    				}
    				batchLogIf(ctx,
    					fmt.Errorf("trying %s: Unable to cleanup failed multipart replication %s on remote %s/%s: %w - this may consume space on remote cluster",
    						humanize.Ordinal(attempts), res.UploadID, tgtBucket, tgtObject, aerr))
    				attempts++
    				time.Sleep(time.Second)
    			}
    		}
    	}()
    
    	var (
    		hr    *hash.Reader
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
Back to top