Search Options

Results per page
Sort
Preferred Languages
Advance

Results 241 - 250 of 304 for consumers (0.42 sec)

  1. docs/contribute/concurrency.md

    available, we need to hold that thread until either the bytes arrive, the stream is closed, or a timeout elapses. If we get bytes but there's nobody asking for them, we buffer them. We don't consider bytes as delivered for flow control until they're consumed by the application.
    
    Consider an application streaming a video over http/2. Perhaps the user pauses the video and the application stops reading bytes from this stream. The buffer will fill up, and flow control prevents the server from sending...
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sun Feb 06 16:35:36 UTC 2022
    - 7K bytes
    - Viewed (0)
  2. src/bufio/scan.go

    			}
    			if n > 0 {
    				s.empties = 0
    				break
    			}
    			loop++
    			if loop > maxConsecutiveEmptyReads {
    				s.setErr(io.ErrNoProgress)
    				break
    			}
    		}
    	}
    }
    
    // advance consumes n bytes of the buffer. It reports whether the advance was legal.
    func (s *Scanner) advance(n int) bool {
    	if n < 0 {
    		s.setErr(ErrNegativeAdvance)
    		return false
    	}
    	if n > s.end-s.start {
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Wed May 21 18:05:26 UTC 2025
    - 14.2K bytes
    - Viewed (0)
  3. docs/en/docs/deployment/https.md

    /// tip
    
    If you are in a hurry or don't care, continue with the next sections for step by step instructions to set everything up with different techniques.
    
    ///
    
    To **learn the basics of HTTPS**, from a consumer perspective, check <a href="https://howhttps.works/" class="external-link" target="_blank">https://howhttps.works/</a>.
    
    Now, from a **developer's perspective**, here are several things to keep in mind while thinking about HTTPS:
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sun Aug 31 19:34:08 UTC 2025
    - 14.3K bytes
    - Viewed (0)
  4. mvnw

      fi
      while IFS="=" read -r key value; do
        # Remove '\r' from value to allow usage on windows as IFS does not consider '\r' as a separator ( considers space, tab, new line ('\n'), and custom '=' )
        safeValue=$(echo "$value" | tr -d '\r')
        case "$key" in wrapperUrl)
          wrapperUrl="$safeValue"
          break
          ;;
        esac
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Oct 14 22:24:15 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  5. compat/maven-model-builder/src/main/java/org/apache/maven/model/building/DefaultModelBuilder.java

    import java.util.Iterator;
    import java.util.LinkedHashSet;
    import java.util.List;
    import java.util.Map;
    import java.util.Objects;
    import java.util.Optional;
    import java.util.Properties;
    import java.util.function.Consumer;
    import java.util.stream.IntStream;
    
    import org.apache.maven.artifact.versioning.DefaultArtifactVersion;
    import org.apache.maven.artifact.versioning.InvalidVersionSpecificationException;
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Sun Mar 30 23:08:08 UTC 2025
    - 55.3K bytes
    - Viewed (0)
  6. src/test/java/jcifs/internal/fscc/SmbInfoAllocationTest.java

            // Decode
            int bytesDecoded = smbInfoAllocation.decode(buffer, 0, buffer.length);
    
            // Verify we read exactly 20 bytes (4 + 4 + 4 + 4 + 4)
            // Note: bytesPerSect is read as Int2 but 4 bytes are consumed (padding)
            assertEquals(20, bytesDecoded);
        }
    
        @Test
        @DisplayName("Test capacity calculation overflow handling")
        void testCapacityCalculationOverflow() throws SMBProtocolDecodingException {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 14.2K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/sso/saml/SamlAuthenticator.java

     * </pre>
     *
     * <h3>Option 2: Set individual SP URLs</h3>
     * <pre>
     * # SP Entity ID (Audience URI in IdP)
     * saml.sp.entityid=https://your-fess-server.example.com/sso/metadata
     *
     * # Assertion Consumer Service URL
     * saml.sp.assertion_consumer_service.url=https://your-fess-server.example.com/sso/
     *
     * # Single Logout Service URL
     * saml.sp.single_logout_service.url=https://your-fess-server.example.com/sso/logout
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Sun Dec 14 01:18:25 UTC 2025
    - 20.2K bytes
    - Viewed (3)
  8. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/http/HcHttpClient.java

            }
    
            formSchemeList.forEach(p -> {
                final FormScheme scheme = p.getFirst();
                final Credentials credentials = p.getSecond();
                scheme.authenticate(credentials, (request, consumer) -> {
    
                    // request header
                    for (final Header header : requestHeaderList) {
                        request.addHeader(header);
                    }
    
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sun Nov 23 12:19:14 UTC 2025
    - 53.7K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/collect/TopKSelector.java

      }
    
      /**
       * Adds each member of {@code elements} as a candidate for the top {@code k} elements. This
       * operation takes amortized linear time in the length of {@code elements}. The iterator is
       * consumed after this operation completes.
       *
       * <p>If all input data to this {@code TopKSelector} is in a single {@code Iterator}, prefer
       * {@link Ordering#leastOf(Iterator, int)}, which provides a simpler API for that use case.
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Aug 31 13:15:26 UTC 2025
    - 11.3K bytes
    - Viewed (0)
  10. guava/src/com/google/common/io/CharStreams.java

       * or all lines have been read and returning the result produced by the processor. Does not close
       * {@code readable}. Note that this method may not fully consume the contents of {@code readable}
       * if the processor stops processing early.
       *
       * <p><b>Users who can use {@code Stream}:</b> If your input is a {@link Reader}, consider
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 29 13:56:24 UTC 2025
    - 11.9K bytes
    - Viewed (0)
Back to top