Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 71 - 80 of 254 for Consume (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. guava/src/com/google/common/collect/IndexedImmutableSet.java

        return CollectSpliterators.indexed(size(), SPLITERATOR_CHARACTERISTICS, this::get);
      }
    
      @Override
      public void forEach(Consumer<? super E> consumer) {
        checkNotNull(consumer);
        int n = size();
        for (int i = 0; i < n; i++) {
          consumer.accept(get(i));
        }
      }
    
      @Override
      @GwtIncompatible
      int copyIntoArray(@Nullable Object[] dst, int offset) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 2.6K bytes
    - Click Count (0)
  2. src/main/java/org/codelibs/core/beans/util/BeanUtil.java

         *
         * @param src The source Bean. Must not be {@literal null}.
         * @param dest The destination Bean. Must not be {@literal null}.
         * @param option The consumer for copy options.
         */
        public static void copyBeanToBean(final Object src, final Object dest, final Consumer<CopyOptions> option) {
            copyBeanToBean(src, dest, buildCopyOptions(option));
        }
    
        /**
         * Copies properties from one Bean to another Bean.
    Created: Fri Apr 03 20:58:12 GMT 2026
    - Last Modified: Thu Jul 31 08:16:49 GMT 2025
    - 23.5K bytes
    - Click Count (0)
  3. src/test/java/jcifs/smb/DosErrorTest.java

            for (int dos : inputs) {
                int nt = findNtStatusOrMinusOne(dos);
                if (nt != -1) {
                    consumer.accept(dos, nt);
                }
            }
    
            // Assert: consumer called exactly for the 3 known codes, with the right arguments
            ArgumentCaptor<Integer> dosCaptor = ArgumentCaptor.forClass(Integer.class);
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 5.9K bytes
    - Click Count (0)
  4. src/test/java/jcifs/smb1/smb1/TransWaitNamedPipeTest.java

            TransWaitNamedPipe pipe = new TransWaitNamedPipe("\\\\pipe\\testPipe");
            byte[] buffer = new byte[10];
    
            // The implementation always returns 0
            int consumed = pipe.readSetupWireFormat(buffer, 0, 4);
            assertEquals(0, consumed, "readSetupWireFormat should always return 0");
        }
    
        @Test
        public void testWriteParametersWireFormat() {
            // Test that writeParametersWireFormat returns 0
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 5.3K bytes
    - Click Count (0)
  5. cmd/os_unix.go

    		return consumed, nil, typ, fmt.Errorf("buf size %d < record length %d", len(buf), dirent.Reclen)
    	}
    	consumed = int(dirent.Reclen)
    	if direntInode(dirent) == 0 { // File absent in directory.
    		return consumed, name, typ, err
    	}
    	switch dirent.Type {
    	case syscall.DT_REG:
    		typ = 0
    	case syscall.DT_DIR:
    		typ = os.ModeDir
    	case syscall.DT_LNK:
    		typ = os.ModeSymlink
    	default:
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 9.3K bytes
    - Click Count (0)
  6. src/test/java/jcifs/smb/RequestParamTest.java

            // Arrange: pick a value and a mocked consumer
            RequestParam rp = RequestParam.NO_RETRY;
    
            // Act: pass to the collaborator
            consumer.accept(rp);
    
            // Assert: interaction happened exactly once with correct argument; no other calls
            verify(consumer, times(1)).accept(RequestParam.NO_RETRY);
            verifyNoMoreInteractions(consumer);
        }
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 5.2K bytes
    - Click Count (0)
  7. src/test/java/org/codelibs/fess/util/ThreadDumpUtilTest.java

                fail("Should throw NullPointerException for null consumer");
            } catch (NullPointerException e) {
                // Expected behavior
            }
        }
    
        @Test
        public void test_processThreadDump_multipleThreads() {
            AtomicInteger threadCount = new AtomicInteger(0);
            AtomicInteger stackTraceCount = new AtomicInteger(0);
    
            Consumer<String> countingConsumer = line -> {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 15.6K bytes
    - Click Count (0)
  8. src/main/java/org/codelibs/fess/util/ThreadDumpUtil.java

            }
        }
    
        /**
         * Processes all thread information and sends it to the provided consumer.
         *
         * @param writer the consumer that will handle each line of thread dump output
         */
        public static void processThreadDump(final Consumer<String> writer) {
            for (final Map.Entry<Thread, StackTraceElement[]> entry : Thread.getAllStackTraces().entrySet()) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 3.3K bytes
    - Click Count (0)
  9. guava/src/com/google/common/collect/CollectSpliterators.java

            this.delegate = delegate;
          }
    
          @Override
          public boolean tryAdvance(Consumer<? super T> action) {
            return delegate.tryAdvance((IntConsumer) i -> action.accept(function.apply(i)));
          }
    
          @Override
          public void forEachRemaining(Consumer<? super T> action) {
            delegate.forEachRemaining((IntConsumer) i -> action.accept(function.apply(i)));
          }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Nov 17 22:50:48 GMT 2025
    - 19.9K bytes
    - Click Count (0)
  10. api/maven-api-annotations/src/main/java/org/apache/maven/api/annotations/Provider.java

     * <p>
     * A type can be marked {@link Consumer} or {@link Provider} but not both. A type is assumed to be
     * {@link Consumer} if it is not marked either {@link Consumer} or {@link Provider}.
     * <p>
     * A package can be marked {@link Provider}. In this case, all types in the package are considered
     * to be a provider type regardless of whether they are marked {@link Consumer} or {@link Provider}.
     *
     * @see Consumer
     * @since 4.0.0
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Tue Dec 10 21:43:27 GMT 2024
    - 1.7K bytes
    - Click Count (0)
Back to Top