Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 321 - 330 of 375 for consumers (0.09 seconds)

  1. impl/maven-core/plugin-manager.txt

    To create the packaging for a plugin a special Maven packaging would be created with an accompanying life-cycle in order to create the plugin metadata required and create an archive of the plugin that can be consumed at runtime.
    
    h3. Creation of an isolated classloader
    
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Jan 22 11:03:29 GMT 2025
    - 12.3K bytes
    - Click Count (0)
  2. 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
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 31.9K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/base/Converter.java

       *     then this is not logically a {@code Converter} at all, and should just implement {@link
       *     Function}.
       */
      @ForOverride
      protected abstract A doBackward(B b);
    
      // API (consumer-side) methods
    
      /**
       * Returns a representation of {@code a} as an instance of type {@code B}.
       *
       * @return the converted value; is null <i>if and only if</i> {@code a} is null
       */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jun 18 21:43:06 GMT 2025
    - 22.8K bytes
    - Click Count (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/HttpUrl.kt

     * model to address problems that the others don't.
     *
     * ### Different URLs should be different
     *
     * Although they have different content, `java.net.URL` considers the following two URLs
     * equal, and the [equals()][Object.equals] method between them returns true:
     *
     *  * https://example.net/
     *
     *  * https://example.com/
     *
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 63.5K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

     *       Future} returned by this class, the next task may still have to wait.</i>.
     *   <li>Once an {@code AsyncCallable} returns a {@code Future}, this class considers that task to
     *       be "done" as soon as <i>that</i> {@code Future} completes in any way. Notably, a {@code
     *       Future} is "completed" even if it is cancelled while its underlying work continues on a
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Sep 23 01:35:55 GMT 2025
    - 22.1K bytes
    - Click Count (0)
  6. src/test/java/org/codelibs/fess/helper/QueryHelperTest.java

        }
    
        @Test
        public void test_buildBaseQuery_invalidQuery() {
            try {
                queryHelper.buildBaseQuery(new QueryContext("field:[invalid", true), ctx -> {
                    // Empty context consumer
                });
                // Some invalid queries might be handled gracefully
            } catch (InvalidQueryException e) {
                // This is expected for malformed queries
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 53.2K bytes
    - Click Count (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
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Fri Feb 07 01:08:54 GMT 2025
    - 51.6K bytes
    - Click Count (0)
  8. 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);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 47.9K bytes
    - Click Count (0)
  9. 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) {
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Fri Feb 06 17:28:40 GMT 2026
    - 22K bytes
    - Click Count (0)
  10. guava/src/com/google/common/collect/Sets.java

    import java.util.Set;
    import java.util.SortedSet;
    import java.util.TreeSet;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.CopyOnWriteArraySet;
    import java.util.function.Consumer;
    import java.util.stream.Collector;
    import java.util.stream.Stream;
    import org.jspecify.annotations.NonNull;
    import org.jspecify.annotations.Nullable;
    
    /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 83K bytes
    - Click Count (0)
Back to Top