Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 291 - 300 of 659 for consumer (0.05 seconds)

  1. build-logic-commons/basics/src/main/kotlin/gradlebuild/basics/kotlindsl/kotlin-dsl-upstream-candidates.kt

    // This file contains members that we should consider to pull upstream
    // and make available to all Kotlin DSL users
    package gradlebuild.basics.kotlindsl
    
    import org.gradle.process.ExecOperations
    import java.io.ByteArrayOutputStream
    import java.io.File
    
    
    /**
     * `dir / "sub"` is the same as `dir.resolve("sub")`.
     *
     * @see [File.resolve]
     */
    operator fun File.div(child: String): File =
        resolve(child)
    
    
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Mon May 19 11:33:57 GMT 2025
    - 965 bytes
    - Click Count (0)
  2. fastapi/.agents/skills/fastapi/references/other-tools.md

    # Other Tools
    
    ## uv
    
    If uv is available, use it to manage dependencies.
    
    ## Ruff
    
    If Ruff is available, use it to lint and format the code. Consider enabling the FastAPI rules.
    
    ## ty
    
    If ty is available, use it to check types.
    
    ## Asyncer
    
    When needing to run blocking code inside of async functions, or async code inside of blocking functions, suggest using Asyncer.
    
    Prefer it over AnyIO or asyncio.
    
    Install:
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Sun Mar 01 10:05:57 GMT 2026
    - 1.5K bytes
    - Click Count (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/idn/Punycode.kt

        // appendCodePoint(). The Punycode algorithm processes code points in increasing code-point
        // order, not in increasing index order.
        val codePoints = mutableListOf<Int>()
    
        // consume all code points before the last delimiter (if there is one)
        //  and copy them to output, fail on any non-basic code point
        val lastDelimiter = string.lastIndexOf('-', limit)
        if (lastDelimiter >= pos) {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 8.6K bytes
    - Click Count (0)
  4. build-logic/cleanup/src/main/java/gradlebuild/cleanup/services/KillLeakingJavaProcesses.java

        static void forEachLeakingJavaProcess(File rootProjectDir, BiConsumer<String, String> action) {
            Pattern commandLineArgsPattern = Pattern.compile(generateLeakingProcessKillPattern(rootProjectDir.getPath()));
            forEachJavaProcess(ps(), commandLineArgsPattern, action);
        }
    
        private static void forEachJavaProcess(List<String> psOutput, Pattern commandLineArgsPattern, BiConsumer<String, String> action) {
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Tue Sep 23 13:49:45 GMT 2025
    - 12K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/util/concurrent/ParametricNullness.java

     *       ImmutableMap.get} returns {@code @Nullable E} because the method can return {@code null}
     *       even on an {@code ImmutableMap<K, @NonNull String>}.
     * </ul>
     *
     * <p>Consumers of this annotation include:
     *
     * <ul>
     *   <li>NullAway, which <a
     *       href="https://github.com/google/guava/issues/6126#issuecomment-1204399671">treats it
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Dec 21 16:20:21 GMT 2024
    - 3.1K bytes
    - Click Count (0)
  6. guava/src/com/google/common/cache/ParametricNullness.java

     *       ImmutableMap.get} returns {@code @Nullable E} because the method can return {@code null}
     *       even on an {@code ImmutableMap<K, @NonNull String>}.
     * </ul>
     *
     * <p>Consumers of this annotation include:
     *
     * <ul>
     *   <li>NullAway, which <a
     *       href="https://github.com/google/guava/issues/6126#issuecomment-1204399671">treats it
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Dec 21 16:20:21 GMT 2024
    - 3.1K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/collect/Cut.java

        return false;
      }
    
      // Prevent "missing hashCode" warning by explicitly forcing subclasses implement it
      @Override
      public abstract int hashCode();
    
      /*
       * The implementation neither produces nor consumes any non-null instance of type C, so
       * casting the type parameter is safe.
       */
      @SuppressWarnings("unchecked")
      static <C extends Comparable> Cut<C> belowAll() {
        return (Cut<C>) BelowAll.INSTANCE;
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Sep 22 18:35:44 GMT 2025
    - 12.4K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java

         * this is no worse than what FutureTask does in that situation. Additionally, because the
         * Future was cancelled, its listeners have been run, so its consumers will not hang.
         *
         * Contrast this to the situation we have if setResult() throws, a situation described below.
         */
        I sourceResult;
        try {
          sourceResult = getDone(localInputFuture);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Feb 20 18:03:37 GMT 2025
    - 10.8K bytes
    - Click Count (0)
  9. src/test/java/jcifs/internal/fscc/FileFsFullSizeInformationTest.java

                assertEquals(callerFree * sectPerAlloc * bytesPerSect, fileFsFullSizeInfo.getFree());
            }
    
            @Test
            @DisplayName("Should return correct number of bytes consumed from buffer")
            void shouldReturnCorrectBytesConsumed() throws SMBProtocolDecodingException {
                // Given - larger buffer than needed
                byte[] buffer = new byte[100];
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 30.5K bytes
    - Click Count (0)
  10. src/test/java/jcifs/smb/SmbFileOutputStreamTest.java

            // These should pass through to the underlying implementation
            assertDoesNotThrow(() -> outputStream.write(data, 0, 10)); // valid - will consume first mock (10)
            assertDoesNotThrow(() -> outputStream.write(data, 5, 5)); // valid - will consume second mock (5)
        }
    
        @Test
        void testAppendMode() throws IOException, CIFSException {
            // Given
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 15.8K bytes
    - Click Count (0)
Back to Top