support RxJava

Author: Sebastian Hoß

README.md

@@ -12,6 +12,7 @@ Java [memoization](https://en.wikipedia.org/wiki/Memoization) library - trade sp
 * Memoize calls to JDK interfaces like `Consumer`, `Function`, `Predicate`, `Supplier`, and more
 * Memoize calls to [jOOL](https://github.com/jOOQ/jOOL) interfaces like `Consumer0..16` and `Function0..16`
 * Memoize calls to [lambda](https://github.com/palatable/lambda) interfaces like `Fn0..8`
+* Memoize calls to [RxJava](https://github.com/ReactiveX/RxJava) interfaces like `Action`, `Cancellable`, and more
 * Use custom caches like [Caffeine](https://github.com/ben-manes/caffeine), [Guava](https://github.com/google/guava/wiki/CachesExplained), [cache2k](https://cache2k.org/), or any other [`ConcurrentMap`](https://docs.oracle.com/en/java/javase/11/docs/api/java.base/java/util/concurrent/ConcurrentMap.html).
 * Use custom cache keys for fine-tuning
 
@@ -22,19 +23,21 @@ Memoize any of the supported types by using the static factory methods supplied
 * `Memoize` if you want to memoize JDK interfaces.
 * `MemoizeJool` if you want to memoize jOOL interfaces.
 * `MemoizeLambda` if you want to memoize lambda interfaces.
+* `MemoizeRx` if you want to memoize RxJava interfaces.
 
 ### Default cache with default cache keys
 
 ```java
 wtf.metio.memoization.jdk.Memoize;
 wtf.metio.memoization.jool.MemoizeJool;
 wtf.metio.memoization.jool.MemoizeLambda;
+wtf.metio.memoization.rxjava.MemoizeRx;
 
 Function<INPUT, OUTPUT> function         = ...;
 Function<INPUT, OUTPUT> memoizedFunction = Memoize.function(function);
 
 Supplier<OUTPUT> supplier                = ...;
-Supplier<OUTPUT> memoizedSupplier        = Memoize.supplier(supplier);
+Supplier<OUTPUT> memoizedSupplier        = MemoizeRx.supplier(supplier);
 
 Function3<T1, T2, T3, OUTPUT> function         = ...;
 Function3<T1, T2, T3, OUTPUT> memoizedFunction = MemoizeJool.function3(function);
@@ -49,14 +52,15 @@ Fn4<T1, T2, T3, T4, OUTPUT> memoizedFunction = MemoizeLambda.fn4(function);
 wtf.metio.memoization.jdk.Memoize;
 wtf.metio.memoization.jool.MemoizeJool;
 wtf.metio.memoization.jool.MemoizeLambda;
+wtf.metio.memoization.rxjava.MemoizeRx;
 
 Function<INPUT, OUTPUT> function         = ...;
 Function<INPUT, KEY> keyFunction         = ...;
 Function<INPUT, OUTPUT> memoizedFunction = Memoize.function(function, keyFunction);
 
 Supplier<OUTPUT> supplier                = ...;
 Supplier<KEY> keySupplier                = ...;
-Supplier<OUTPUT> memoizedSupplier        = Memoize.supplier(supplier, keySupplier);
+Supplier<OUTPUT> memoizedSupplier        = MemoizeRx.supplier(supplier, keySupplier);
 
 Function3<T1, T2, T3, OUTPUT> function         = ...;
 Function3<T1, T2, T3, KEY> keyFunction         = ...;
@@ -73,6 +77,7 @@ Fn4<T1, T2, T3, T4, OUTPUT> memoizedFunction = MemoizeLambda.fn4(function, keyFu
 wtf.metio.memoization.jdk.Memoize;
 wtf.metio.memoization.jool.MemoizeJool;
 wtf.metio.memoization.jool.MemoizeLambda;
+wtf.metio.memoization.rxjava.MemoizeRx;
 
 // memoize in cache2k cache
 Function<INPUT, OUTPUT> function         = ...;
@@ -82,7 +87,7 @@ Function<INPUT, OUTPUT> memoizedFunction = Memoize.function(function, cache.asMa
 // memoize in Caffeine cache
 Supplier<OUTPUT> supplier                = ...;
 Cache<String, OUTPUT> cache              = ...; // com.github.benmanes.caffeine.cache.Cache
-Supplier<OUTPUT> memoizedSupplier        = Memoize.supplier(supplier, cache.asMap());
+Supplier<OUTPUT> memoizedSupplier        = MemoizeRx.supplier(supplier, cache.asMap());
 
 // memoize in Guava cache
 Function3<T1, T2, T3, OUTPUT> function         = ...;
@@ -101,6 +106,7 @@ Fn4<T1, T2, T3, T4, OUTPUT> memoizedFunction = MemoizeLambda.fn4(function, cache
 wtf.metio.memoization.jdk.Memoize;
 wtf.metio.memoization.jool.MemoizeJool;
 wtf.metio.memoization.jool.MemoizeLambda;
+wtf.metio.memoization.rxjava.MemoizeRx;
 
 // memoize in cache2k cache
 Function<INPUT, OUTPUT> function         = ...;
@@ -112,7 +118,7 @@ Function<INPUT, OUTPUT> memoizedFunction = Memoize.function(function, keyFunctio
 Supplier<OUTPUT> supplier                = ...;
 Supplier<KEY> keySupplier                = ...;
 Cache<KEY, OUTPUT> cache                 = ...; // com.github.benmanes.caffeine.cache.Cache
-Supplier<OUTPUT> memoizedSupplier        = Memoize.supplier(supplier, keySupplier, cache.asMap());
+Supplier<OUTPUT> memoizedSupplier        = MemoizeRx.supplier(supplier, keySupplier, cache.asMap());
 
 // memoize in Guava cache
 Function3<T1, T2, T3, OUTPUT> function         = ...;
@@ -158,6 +164,14 @@ In order to use this project, declare the following dependencies in your project
         <version>${version.memoization}</version>
     </dependency>
     <!-- support for lambda interfaces -->
+
+    <!-- support for RxJava interfaces -->
+    <dependency>
+        <groupId>wtf.metio.memoization</groupId>
+        <artifactId>memoization-rxjava</artifactId>
+        <version>${version.memoization}</version>
+    </dependency>
+    <!-- support for RxJava interfaces -->
 </dependencies>
 ```
 

memoization-core/src/main/java/wtf/metio/memoization/core/MemoizationDefaults.java

@@ -34,6 +34,8 @@ public static Supplier<String> staticKey() {
      * @return The constructed cache key.
      */
     public static String hashCodes(final Object... values) {
+//        return Arrays.hashCode(values);
+
         return Arrays.stream(values)
                 .map(Object::hashCode)
                 .map(Objects::toString)

memoization-jdk/src/main/java/wtf/metio/memoization/jdk/BiConsumerMemoizer.java

@@ -19,7 +19,7 @@ final class BiConsumerMemoizer<FIRST, SECOND, KEY>
     private final BiFunction<FIRST, SECOND, KEY> keyFunction;
     private final BiConsumer<FIRST, SECOND> biConsumer;
 
-    public BiConsumerMemoizer(
+    BiConsumerMemoizer(
             final ConcurrentMap<KEY, KEY> cache,
             final BiFunction<FIRST, SECOND, KEY> keyFunction,
             final BiConsumer<FIRST, SECOND> biConsumer) {

memoization-jdk/src/main/java/wtf/metio/memoization/jdk/BiPredicateMemoizer.java

@@ -19,7 +19,7 @@ final class BiPredicateMemoizer<FIRST, SECOND, KEY>
     private final BiFunction<FIRST, SECOND, KEY> keyFunction;
     private final BiPredicate<FIRST, SECOND> biPredicate;
 
-    public BiPredicateMemoizer(
+    BiPredicateMemoizer(
             final ConcurrentMap<KEY, Boolean> cache,
             final BiFunction<FIRST, SECOND, KEY> keyFunction,
             final BiPredicate<FIRST, SECOND> biPredicate) {

memoization-jdk/src/main/java/wtf/metio/memoization/jdk/BooleanSupplierMemoizer.java

@@ -25,9 +25,9 @@ final class BooleanSupplierMemoizer<KEY>
             final BooleanSupplier supplier) {
         super(cache);
         this.keySupplier = requireNonNull(keySupplier,
-                "Provide a key function, might just be 'MemoizationDefaults.staticKey()'.");
+                "Provide a key supplier, might just be 'MemoizationDefaults.staticKey()'.");
         this.supplier = requireNonNull(supplier,
-                "Cannot memoize a NULL Supplier - provide an actual Supplier to fix this.");
+                "Cannot memoize a NULL BooleanSupplier - provide an actual BooleanSupplier to fix this.");
     }
 
     @Override

memoization-jdk/src/main/java/wtf/metio/memoization/jdk/CallableMemoizer.java

@@ -21,21 +21,21 @@ final class CallableMemoizer<OUTPUT, KEY>
     private final Supplier<KEY> keySupplier;
     private final Callable<OUTPUT> callable;
 
-    public CallableMemoizer(
+    CallableMemoizer(
             final ConcurrentMap<KEY, OUTPUT> cache,
             final Supplier<KEY> keySupplier,
             final Callable<OUTPUT> callable) {
         super(cache);
         this.keySupplier = requireNonNull(keySupplier,
-                "Provide a key function, might just be 'MemoizationDefaults.staticKey()'.");
+                "Provide a key supplier, might just be 'MemoizationDefaults.staticKey()'.");
         this.callable = requireNonNull(callable,
                 "Cannot memoize a NULL Callable - provide an actual Callable to fix this.");
     }
 
     @Override
     public OUTPUT call() throws Exception {
         try {
-            return computeIfAbsent(keySupplier.get(), givenKey -> {
+            return computeIfAbsent(keySupplier.get(), key -> {
                 try {
                     return callable.call();
                 } catch (final Exception exception) {

memoization-jdk/src/main/java/wtf/metio/memoization/jdk/ConsumerMemoizer.java

@@ -32,9 +32,9 @@ final class ConsumerMemoizer<INPUT, KEY>
 
     @Override
     public void accept(final INPUT input) {
-        computeIfAbsent(keyFunction.apply(input), givenKey -> {
+        computeIfAbsent(keyFunction.apply(input), key -> {
             consumer.accept(input);
-            return givenKey;
+            return key;
         });
     }
 

memoization-jdk/src/main/java/wtf/metio/memoization/jdk/DoubleBinaryOperatorMemoizer.java

@@ -18,7 +18,7 @@ final class DoubleBinaryOperatorMemoizer<KEY>
     private final DoubleBinaryFunction<KEY> keyFunction;
     private final DoubleBinaryOperator operator;
 
-    public DoubleBinaryOperatorMemoizer(
+    DoubleBinaryOperatorMemoizer(
             final ConcurrentMap<KEY, Double> cache,
             final DoubleBinaryFunction<KEY> keyFunction,
             final DoubleBinaryOperator operator) {

memoization-jdk/src/main/java/wtf/metio/memoization/jdk/DoubleSupplierMemoizer.java

@@ -25,7 +25,7 @@ final class DoubleSupplierMemoizer<KEY>
             final DoubleSupplier supplier) {
         super(cache);
         this.keySupplier = requireNonNull(keySupplier,
-                "Provide a key function, might just be 'MemoizationDefaults.staticKey()'.");
+                "Provide a key supplier, might just be 'MemoizationDefaults.staticKey()'.");
         this.supplier = requireNonNull(supplier,
                 "Cannot memoize a NULL Supplier - provide an actual Supplier to fix this.");
     }

memoization-jdk/src/main/java/wtf/metio/memoization/jdk/FunctionMemoizer.java

@@ -30,7 +30,7 @@ final class FunctionMemoizer<INPUT, KEY, OUTPUT>
 
     @Override
     public OUTPUT apply(final INPUT input) {
-        return computeIfAbsent(keyFunction.apply(input), givenKey -> function.apply(input));
+        return computeIfAbsent(keyFunction.apply(input), key -> function.apply(input));
     }
 
 }

memoization-jdk/src/main/java/wtf/metio/memoization/jdk/IntBinaryOperatorMemoizer.java

@@ -18,7 +18,7 @@ final class IntBinaryOperatorMemoizer<KEY>
     private final IntBinaryFunction<KEY> keyFunction;
     private final IntBinaryOperator operator;
 
-    public IntBinaryOperatorMemoizer(
+    IntBinaryOperatorMemoizer(
             final ConcurrentMap<KEY, Integer> cache,
             final IntBinaryFunction<KEY> keyFunction,
             final IntBinaryOperator operator) {

memoization-jdk/src/main/java/wtf/metio/memoization/jdk/IntSupplierMemoizer.java

@@ -25,7 +25,7 @@ final class IntSupplierMemoizer<KEY>
             final IntSupplier supplier) {
         super(cache);
         this.keySupplier = requireNonNull(keySupplier,
-                "Provide a key function, might just be 'MemoizationDefaults.staticKey()'.");
+                "Provide a key supplier, might just be 'MemoizationDefaults.staticKey()'.");
         this.supplier = requireNonNull(supplier,
                 "Cannot memoize a NULL Supplier - provide an actual Supplier to fix this.");
     }

memoization-jdk/src/main/java/wtf/metio/memoization/jdk/LongBinaryOperatorMemoizer.java

@@ -18,7 +18,7 @@ final class LongBinaryOperatorMemoizer<KEY>
     private final LongBinaryFunction<KEY> keyFunction;
     private final LongBinaryOperator operator;
 
-    public LongBinaryOperatorMemoizer(
+    LongBinaryOperatorMemoizer(
             final ConcurrentMap<KEY, Long> cache,
             final LongBinaryFunction<KEY> keyFunction,
             final LongBinaryOperator operator) {

memoization-jdk/src/main/java/wtf/metio/memoization/jdk/LongConsumerMemoizer.java

@@ -19,14 +19,14 @@ final class LongConsumerMemoizer<KEY>
     private final LongFunction<KEY> keyFunction;
     private final LongConsumer consumer;
 
-    public LongConsumerMemoizer(
+    LongConsumerMemoizer(
             final ConcurrentMap<KEY, KEY> cache,
             final LongFunction<KEY> keyFunction,
             final LongConsumer consumer) {
         super(cache);
         this.keyFunction = requireNonNull(keyFunction, "Provide a key function.");
         this.consumer = requireNonNull(consumer,
-                "Cannot memoize a NULL Consumer - provide an actual Consumer to fix this.");
+                "Cannot memoize a NULL LongConsumer - provide an actual LongConsumer to fix this.");
     }
 
     @Override

memoization-jdk/src/main/java/wtf/metio/memoization/jdk/LongSupplierMemoizer.java

@@ -25,7 +25,7 @@ final class LongSupplierMemoizer<KEY>
             final LongSupplier supplier) {
         super(cache);
         this.keySupplier = requireNonNull(keySupplier,
-                "Provide a key function, might just be 'MemoizationDefaults.staticKey()'.");
+                "Provide a key supplier, might just be 'MemoizationDefaults.staticKey()'.");
         this.supplier = requireNonNull(supplier,
                 "Cannot memoize a NULL Supplier - provide an actual Supplier to fix this.");
     }