Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 61 for Reactor (0.04 sec)

  1. android/guava/src/com/google/common/eventbus/EventBus.java

     * href="https://github.com/ReactiveX/RxAndroid">RxAndroid</a> extension if you are building for
     * Android) or <a href="https://projectreactor.io/">Project Reactor</a>. (For the basics of
     * translating code from using an event bus to using a reactive-streams framework, see these two
     * guides: <a href="https://blog.jkl.gg/implementing-an-event-bus-with-rxjava-rxbus/">1</a>, <a
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/core/collection/CollectionsUtil.java

         * @param c the collection of elements to be placed in the vector
         * @return a new instance of {@link Vector}
         * @see Vector#Vector(Collection)
         */
        public static <E> Vector<E> newVector(final Collection<? extends E> c) {
            return new Vector<>(c);
        }
    
        /**
         * Creates and returns a new instance of {@link Vector}.
         *
         * @param <E> the element type of {@link Vector}
    Registered: Fri Sep 05 20:58:11 UTC 2025
    - Last Modified: Thu Jul 31 08:16:49 UTC 2025
    - 49.9K bytes
    - Viewed (0)
  3. CHANGELOG/CHANGELOG-1.23.md

    - Client-go: pass `DeleteOptions` down to the fake client `Reactor` ([#102945](https://github.com/kubernetes/kubernetes/pull/102945), [@chenchun](https://github.com/chenchun))
    Registered: Fri Sep 05 09:05:11 UTC 2025
    - Last Modified: Tue Feb 28 21:06:52 UTC 2023
    - 424.5K bytes
    - Viewed (0)
  4. src/test/java/org/codelibs/core/collection/EnumerationIteratorTest.java

        @SuppressWarnings("unused")
        @Test
        public void testIterable() throws Exception {
            final Vector<String> vector = new Vector<String>();
            vector.add("a");
            vector.add("b");
            int count = 0;
            for (final String s : iterable(vector.elements())) {
                ++count;
            }
            assertThat(count, is(2));
        }
    
        /**
         * Test method for
    Registered: Fri Sep 05 20:58:11 UTC 2025
    - Last Modified: Sat May 10 01:32:17 UTC 2025
    - 3.4K bytes
    - Viewed (0)
  5. samples/guide/src/main/java/okhttp3/recipes/kt/PostStreaming.kt

              sink.writeUtf8("-------\n")
              for (i in 2..997) {
                sink.writeUtf8(String.format(" * $i = ${factor(i)}\n"))
              }
            }
    
            private fun factor(n: Int): String {
              for (i in 2 until n) {
                val x = n / i
                if (x * i == n) return "${factor(x)} × $i"
              }
              return n.toString()
            }
          }
    
        val request =
          Request(
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  6. src/test/java/org/codelibs/fess/helper/QueryHelperTest.java

                    Map.of("_default", List.of("QUERY1")), //
                    Set.of("QUERY1"), //
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 52.6K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/core/collection/LruHashMap.java

        private static final long serialVersionUID = 1L;
    
        /**
         * Default initial capacity.
         */
        protected static final int DEFAULT_INITIAL_CAPACITY = 16;
    
        /**
         * Default load factor.
         */
        protected static final float DEFAULT_LOAD_FACTOR = 0.75f;
    
        /**
         * Upper limit on the number of entries.
         */
        protected final int limitSize;
    
        /**
    Registered: Fri Sep 05 20:58:11 UTC 2025
    - Last Modified: Thu Jun 19 09:12:22 UTC 2025
    - 2.3K bytes
    - Viewed (0)
  8. android/guava-testlib/src/com/google/common/collect/testing/TestsForListsInJavaUtil.java

            .createTestSuite();
      }
    
      // We are testing Vector / testing our tests on Vector.
      @SuppressWarnings("JdkObsolete")
      private Test testsForVector() {
        return ListTestSuiteBuilder.using(
                new TestStringListGenerator() {
                  @Override
                  protected List<String> create(String[] elements) {
                    return new Vector<>(MinimalCollection.of(elements));
                  }
                })
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Sep 04 15:04:05 UTC 2025
    - 12K bytes
    - Viewed (0)
  9. samples/guide/src/main/java/okhttp3/recipes/PostStreaming.java

            sink.writeUtf8("-------\n");
            for (int i = 2; i <= 997; i++) {
              sink.writeUtf8(String.format(" * %s = %s\n", i, factor(i)));
            }
          }
    
          private String factor(int n) {
            for (int i = 2; i < n; i++) {
              int x = n / i;
              if (x * i == n) return factor(x) + " × " + i;
            }
            return Integer.toString(n);
          }
        };
    
        Request request = new Request.Builder()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jul 06 03:18:15 UTC 2018
    - 2.1K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/collect/Hashing.java

        // Round down to the nearest power of 2.
        expectedEntries = max(expectedEntries, 2);
        int tableSize = Integer.highestOneBit(expectedEntries);
        // Check to make sure that we will not exceed the maximum load factor.
        if (expectedEntries > (int) (loadFactor * tableSize)) {
          tableSize <<= 1;
          return (tableSize > 0) ? tableSize : MAX_TABLE_SIZE;
        }
        return tableSize;
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 2.5K bytes
    - Viewed (0)
Back to top