Package com.mewna.catnip.util.rx

Class RxHelpers

java.lang.Object
com.mewna.catnip.util.rx.RxHelpers
public final class RxHelpers extends Object
A collection of utility methods to help make using Rx not quite so potato when trying to convert between various things.
Since:
5/18/19.
Author:
amy

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final ExecutorService
    FORK_JOIN_POOL
     
    static final io.reactivex.rxjava3.core.Scheduler
    FORK_JOIN_SCHEDULER
     

  • Method Summary

    Modifier and Type
    Method
    Description
    static io.reactivex.rxjava3.core.Completable
    completedCompletable(Catnip catnip)
     
    static <T> io.reactivex.rxjava3.core.Observable<T>
    futureToObservable(CompletableFuture<T> future)
     
    static <T> io.reactivex.rxjava3.core.Maybe<T>
    nullableToMaybe(T nullable)
     
    static <A, B> io.reactivex.rxjava3.core.Single<org.javatuples.Pair<A,B>>
    resolveMany(io.reactivex.rxjava3.core.Maybe<A> a, io.reactivex.rxjava3.core.Maybe<B> b)
     
    static <A, B, C> io.reactivex.rxjava3.core.Single<org.javatuples.Triplet<A,B,C>>
    resolveMany(io.reactivex.rxjava3.core.Maybe<A> a, io.reactivex.rxjava3.core.Maybe<B> b, io.reactivex.rxjava3.core.Maybe<C> c)
     
    static <A, B, C, D> io.reactivex.rxjava3.core.Single<org.javatuples.Quartet<A,B,C,D>>
    resolveMany(io.reactivex.rxjava3.core.Maybe<A> a, io.reactivex.rxjava3.core.Maybe<B> b, io.reactivex.rxjava3.core.Maybe<C> c, io.reactivex.rxjava3.core.Maybe<D> d)
     
    static <A, B, C, D, E>
    io.reactivex.rxjava3.core.Single<org.javatuples.Quintet<A,B,C,D,E>>
    resolveMany(io.reactivex.rxjava3.core.Maybe<A> a, io.reactivex.rxjava3.core.Maybe<B> b, io.reactivex.rxjava3.core.Maybe<C> c, io.reactivex.rxjava3.core.Maybe<D> d, io.reactivex.rxjava3.core.Maybe<E> e)
     
    static <A, B, C, D, E, F>
    io.reactivex.rxjava3.core.Single<org.javatuples.Sextet<A,B,C,D,E,F>>
    resolveMany(io.reactivex.rxjava3.core.Maybe<A> a, io.reactivex.rxjava3.core.Maybe<B> b, io.reactivex.rxjava3.core.Maybe<C> c, io.reactivex.rxjava3.core.Maybe<D> d, io.reactivex.rxjava3.core.Maybe<E> e, io.reactivex.rxjava3.core.Maybe<F> f)
     
    static <A, B, C, D, E, F, G>
    io.reactivex.rxjava3.core.Single<org.javatuples.Septet<A,B,C,D,E,F,G>>
    resolveMany(io.reactivex.rxjava3.core.Maybe<A> a, io.reactivex.rxjava3.core.Maybe<B> b, io.reactivex.rxjava3.core.Maybe<C> c, io.reactivex.rxjava3.core.Maybe<D> d, io.reactivex.rxjava3.core.Maybe<E> e, io.reactivex.rxjava3.core.Maybe<F> f, io.reactivex.rxjava3.core.Maybe<G> g)
     
    static <A, B, C, D, E, F, G, H>
    io.reactivex.rxjava3.core.Single<org.javatuples.Octet<A,B,C,D,E,F,G,H>>
    resolveMany(io.reactivex.rxjava3.core.Maybe<A> a, io.reactivex.rxjava3.core.Maybe<B> b, io.reactivex.rxjava3.core.Maybe<C> c, io.reactivex.rxjava3.core.Maybe<D> d, io.reactivex.rxjava3.core.Maybe<E> e, io.reactivex.rxjava3.core.Maybe<F> f, io.reactivex.rxjava3.core.Maybe<G> g, io.reactivex.rxjava3.core.Maybe<H> h)
     
    static <A, B, C, D, E, F, G, H, I>
    io.reactivex.rxjava3.core.Single<org.javatuples.Ennead<A,B,C,D,E,F,G,H,I>>
    resolveMany(io.reactivex.rxjava3.core.Maybe<A> a, io.reactivex.rxjava3.core.Maybe<B> b, io.reactivex.rxjava3.core.Maybe<C> c, io.reactivex.rxjava3.core.Maybe<D> d, io.reactivex.rxjava3.core.Maybe<E> e, io.reactivex.rxjava3.core.Maybe<F> f, io.reactivex.rxjava3.core.Maybe<G> g, io.reactivex.rxjava3.core.Maybe<H> h, io.reactivex.rxjava3.core.Maybe<I> i)
     
    static <A, B, C, D, E, F, G, H, I, J>
    io.reactivex.rxjava3.core.Single<org.javatuples.Decade<A,B,C,D,E,F,G,H,I,J>>
    resolveMany(io.reactivex.rxjava3.core.Maybe<A> a, io.reactivex.rxjava3.core.Maybe<B> b, io.reactivex.rxjava3.core.Maybe<C> c, io.reactivex.rxjava3.core.Maybe<D> d, io.reactivex.rxjava3.core.Maybe<E> e, io.reactivex.rxjava3.core.Maybe<F> f, io.reactivex.rxjava3.core.Maybe<G> g, io.reactivex.rxjava3.core.Maybe<H> h, io.reactivex.rxjava3.core.Maybe<I> i, io.reactivex.rxjava3.core.Maybe<J> j)
     
    static <A, B> io.reactivex.rxjava3.core.Single<org.javatuples.Pair<A,B>>
    resolveMany(io.reactivex.rxjava3.core.Single<A> a, io.reactivex.rxjava3.core.Single<B> b)
     
    static <A, B, C> io.reactivex.rxjava3.core.Single<org.javatuples.Triplet<A,B,C>>
    resolveMany(io.reactivex.rxjava3.core.Single<A> a, io.reactivex.rxjava3.core.Single<B> b, io.reactivex.rxjava3.core.Single<C> c)
     
    static <A, B, C, D> io.reactivex.rxjava3.core.Single<org.javatuples.Quartet<A,B,C,D>>
    resolveMany(io.reactivex.rxjava3.core.Single<A> a, io.reactivex.rxjava3.core.Single<B> b, io.reactivex.rxjava3.core.Single<C> c, io.reactivex.rxjava3.core.Single<D> d)
     
    static <A, B, C, D, E>
    io.reactivex.rxjava3.core.Single<org.javatuples.Quintet<A,B,C,D,E>>
    resolveMany(io.reactivex.rxjava3.core.Single<A> a, io.reactivex.rxjava3.core.Single<B> b, io.reactivex.rxjava3.core.Single<C> c, io.reactivex.rxjava3.core.Single<D> d, io.reactivex.rxjava3.core.Single<E> e)
     
    static <A, B, C, D, E, F>
    io.reactivex.rxjava3.core.Single<org.javatuples.Sextet<A,B,C,D,E,F>>
    resolveMany(io.reactivex.rxjava3.core.Single<A> a, io.reactivex.rxjava3.core.Single<B> b, io.reactivex.rxjava3.core.Single<C> c, io.reactivex.rxjava3.core.Single<D> d, io.reactivex.rxjava3.core.Single<E> e, io.reactivex.rxjava3.core.Single<F> f)
     
    static <A, B, C, D, E, F, G>
    io.reactivex.rxjava3.core.Single<org.javatuples.Septet<A,B,C,D,E,F,G>>
    resolveMany(io.reactivex.rxjava3.core.Single<A> a, io.reactivex.rxjava3.core.Single<B> b, io.reactivex.rxjava3.core.Single<C> c, io.reactivex.rxjava3.core.Single<D> d, io.reactivex.rxjava3.core.Single<E> e, io.reactivex.rxjava3.core.Single<F> f, io.reactivex.rxjava3.core.Single<G> g)
     
    static <A, B, C, D, E, F, G, H>
    io.reactivex.rxjava3.core.Single<org.javatuples.Octet<A,B,C,D,E,F,G,H>>
    resolveMany(io.reactivex.rxjava3.core.Single<A> a, io.reactivex.rxjava3.core.Single<B> b, io.reactivex.rxjava3.core.Single<C> c, io.reactivex.rxjava3.core.Single<D> d, io.reactivex.rxjava3.core.Single<E> e, io.reactivex.rxjava3.core.Single<F> f, io.reactivex.rxjava3.core.Single<G> g, io.reactivex.rxjava3.core.Single<H> h)
     
    static <A, B, C, D, E, F, G, H, I>
    io.reactivex.rxjava3.core.Single<org.javatuples.Ennead<A,B,C,D,E,F,G,H,I>>
    resolveMany(io.reactivex.rxjava3.core.Single<A> a, io.reactivex.rxjava3.core.Single<B> b, io.reactivex.rxjava3.core.Single<C> c, io.reactivex.rxjava3.core.Single<D> d, io.reactivex.rxjava3.core.Single<E> e, io.reactivex.rxjava3.core.Single<F> f, io.reactivex.rxjava3.core.Single<G> g, io.reactivex.rxjava3.core.Single<H> h, io.reactivex.rxjava3.core.Single<I> i)
     
    static <A, B, C, D, E, F, G, H, I, J>
    io.reactivex.rxjava3.core.Single<org.javatuples.Decade<A,B,C,D,E,F,G,H,I,J>>
    resolveMany(io.reactivex.rxjava3.core.Single<A> a, io.reactivex.rxjava3.core.Single<B> b, io.reactivex.rxjava3.core.Single<C> c, io.reactivex.rxjava3.core.Single<D> d, io.reactivex.rxjava3.core.Single<E> e, io.reactivex.rxjava3.core.Single<F> f, io.reactivex.rxjava3.core.Single<G> g, io.reactivex.rxjava3.core.Single<H> h, io.reactivex.rxjava3.core.Single<I> i, io.reactivex.rxjava3.core.Single<J> j)
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Field Details

    • FORK_JOIN_POOL

      public static final ExecutorService FORK_JOIN_POOL

    • FORK_JOIN_SCHEDULER

      public static final io.reactivex.rxjava3.core.Scheduler FORK_JOIN_SCHEDULER

  • Method Details

    • futureToObservable

      public static <T> io.reactivex.rxjava3.core.Observable<T> futureToObservable(CompletableFuture<T> future)

    • completedCompletable

      public static io.reactivex.rxjava3.core.Completable completedCompletable(@Nonnull Catnip catnip)

    • nullableToMaybe

      public static <T> io.reactivex.rxjava3.core.Maybe<T> nullableToMaybe(@Nullable T nullable)

    • resolveMany

      public static <A, B> io.reactivex.rxjava3.core.Single<org.javatuples.Pair<A,B>> resolveMany(@Nonnull io.reactivex.rxjava3.core.Maybe<A> a, @Nonnull io.reactivex.rxjava3.core.Maybe<B> b)

    • resolveMany

      public static <A, B, C> io.reactivex.rxjava3.core.Single<org.javatuples.Triplet<A,B,C>> resolveMany(@Nonnull io.reactivex.rxjava3.core.Maybe<A> a, @Nonnull io.reactivex.rxjava3.core.Maybe<B> b, @Nonnull io.reactivex.rxjava3.core.Maybe<C> c)

    • resolveMany

      public static <A, B, C, D> io.reactivex.rxjava3.core.Single<org.javatuples.Quartet<A,B,C,D>> resolveMany(@Nonnull io.reactivex.rxjava3.core.Maybe<A> a, @Nonnull io.reactivex.rxjava3.core.Maybe<B> b, @Nonnull io.reactivex.rxjava3.core.Maybe<C> c, @Nonnull io.reactivex.rxjava3.core.Maybe<D> d)

    • resolveMany

      public static <A, B, C, D, E> io.reactivex.rxjava3.core.Single<org.javatuples.Quintet<A,B,C,D,E>> resolveMany(@Nonnull io.reactivex.rxjava3.core.Maybe<A> a, @Nonnull io.reactivex.rxjava3.core.Maybe<B> b, @Nonnull io.reactivex.rxjava3.core.Maybe<C> c, @Nonnull io.reactivex.rxjava3.core.Maybe<D> d, @Nonnull io.reactivex.rxjava3.core.Maybe<E> e)

    • resolveMany

      public static <A, B, C, D, E, F> io.reactivex.rxjava3.core.Single<org.javatuples.Sextet<A,B,C,D,E,F>> resolveMany(@Nonnull io.reactivex.rxjava3.core.Maybe<A> a, @Nonnull io.reactivex.rxjava3.core.Maybe<B> b, @Nonnull io.reactivex.rxjava3.core.Maybe<C> c, @Nonnull io.reactivex.rxjava3.core.Maybe<D> d, @Nonnull io.reactivex.rxjava3.core.Maybe<E> e, @Nonnull io.reactivex.rxjava3.core.Maybe<F> f)

    • resolveMany

      public static <A, B, C, D, E, F, G> io.reactivex.rxjava3.core.Single<org.javatuples.Septet<A,B,C,D,E,F,G>> resolveMany(@Nonnull io.reactivex.rxjava3.core.Maybe<A> a, @Nonnull io.reactivex.rxjava3.core.Maybe<B> b, @Nonnull io.reactivex.rxjava3.core.Maybe<C> c, @Nonnull io.reactivex.rxjava3.core.Maybe<D> d, @Nonnull io.reactivex.rxjava3.core.Maybe<E> e, @Nonnull io.reactivex.rxjava3.core.Maybe<F> f, @Nonnull io.reactivex.rxjava3.core.Maybe<G> g)

    • resolveMany

      public static <A, B, C, D, E, F, G, H> io.reactivex.rxjava3.core.Single<org.javatuples.Octet<A,B,C,D,E,F,G,H>> resolveMany(@Nonnull io.reactivex.rxjava3.core.Maybe<A> a, @Nonnull io.reactivex.rxjava3.core.Maybe<B> b, @Nonnull io.reactivex.rxjava3.core.Maybe<C> c, @Nonnull io.reactivex.rxjava3.core.Maybe<D> d, @Nonnull io.reactivex.rxjava3.core.Maybe<E> e, @Nonnull io.reactivex.rxjava3.core.Maybe<F> f, @Nonnull io.reactivex.rxjava3.core.Maybe<G> g, @Nonnull io.reactivex.rxjava3.core.Maybe<H> h)

    • resolveMany

      public static <A, B, C, D, E, F, G, H, I> io.reactivex.rxjava3.core.Single<org.javatuples.Ennead<A,B,C,D,E,F,G,H,I>> resolveMany(@Nonnull io.reactivex.rxjava3.core.Maybe<A> a, @Nonnull io.reactivex.rxjava3.core.Maybe<B> b, @Nonnull io.reactivex.rxjava3.core.Maybe<C> c, @Nonnull io.reactivex.rxjava3.core.Maybe<D> d, @Nonnull io.reactivex.rxjava3.core.Maybe<E> e, @Nonnull io.reactivex.rxjava3.core.Maybe<F> f, @Nonnull io.reactivex.rxjava3.core.Maybe<G> g, @Nonnull io.reactivex.rxjava3.core.Maybe<H> h, @Nonnull io.reactivex.rxjava3.core.Maybe<I> i)

    • resolveMany

      public static <A, B, C, D, E, F, G, H, I, J> io.reactivex.rxjava3.core.Single<org.javatuples.Decade<A,B,C,D,E,F,G,H,I,J>> resolveMany(@Nonnull io.reactivex.rxjava3.core.Maybe<A> a, @Nonnull io.reactivex.rxjava3.core.Maybe<B> b, @Nonnull io.reactivex.rxjava3.core.Maybe<C> c, @Nonnull io.reactivex.rxjava3.core.Maybe<D> d, @Nonnull io.reactivex.rxjava3.core.Maybe<E> e, @Nonnull io.reactivex.rxjava3.core.Maybe<F> f, @Nonnull io.reactivex.rxjava3.core.Maybe<G> g, @Nonnull io.reactivex.rxjava3.core.Maybe<H> h, @Nonnull io.reactivex.rxjava3.core.Maybe<I> i, @Nonnull io.reactivex.rxjava3.core.Maybe<J> j)

    • resolveMany

      public static <A, B> io.reactivex.rxjava3.core.Single<org.javatuples.Pair<A,B>> resolveMany(@Nonnull io.reactivex.rxjava3.core.Single<A> a, @Nonnull io.reactivex.rxjava3.core.Single<B> b)

    • resolveMany

      public static <A, B, C> io.reactivex.rxjava3.core.Single<org.javatuples.Triplet<A,B,C>> resolveMany(@Nonnull io.reactivex.rxjava3.core.Single<A> a, @Nonnull io.reactivex.rxjava3.core.Single<B> b, @Nonnull io.reactivex.rxjava3.core.Single<C> c)

    • resolveMany

      public static <A, B, C, D> io.reactivex.rxjava3.core.Single<org.javatuples.Quartet<A,B,C,D>> resolveMany(@Nonnull io.reactivex.rxjava3.core.Single<A> a, @Nonnull io.reactivex.rxjava3.core.Single<B> b, @Nonnull io.reactivex.rxjava3.core.Single<C> c, @Nonnull io.reactivex.rxjava3.core.Single<D> d)

    • resolveMany

      public static <A, B, C, D, E> io.reactivex.rxjava3.core.Single<org.javatuples.Quintet<A,B,C,D,E>> resolveMany(@Nonnull io.reactivex.rxjava3.core.Single<A> a, @Nonnull io.reactivex.rxjava3.core.Single<B> b, @Nonnull io.reactivex.rxjava3.core.Single<C> c, @Nonnull io.reactivex.rxjava3.core.Single<D> d, @Nonnull io.reactivex.rxjava3.core.Single<E> e)

    • resolveMany

      public static <A, B, C, D, E, F> io.reactivex.rxjava3.core.Single<org.javatuples.Sextet<A,B,C,D,E,F>> resolveMany(@Nonnull io.reactivex.rxjava3.core.Single<A> a, @Nonnull io.reactivex.rxjava3.core.Single<B> b, @Nonnull io.reactivex.rxjava3.core.Single<C> c, @Nonnull io.reactivex.rxjava3.core.Single<D> d, @Nonnull io.reactivex.rxjava3.core.Single<E> e, @Nonnull io.reactivex.rxjava3.core.Single<F> f)

    • resolveMany

      public static <A, B, C, D, E, F, G> io.reactivex.rxjava3.core.Single<org.javatuples.Septet<A,B,C,D,E,F,G>> resolveMany(@Nonnull io.reactivex.rxjava3.core.Single<A> a, @Nonnull io.reactivex.rxjava3.core.Single<B> b, @Nonnull io.reactivex.rxjava3.core.Single<C> c, @Nonnull io.reactivex.rxjava3.core.Single<D> d, @Nonnull io.reactivex.rxjava3.core.Single<E> e, @Nonnull io.reactivex.rxjava3.core.Single<F> f, @Nonnull io.reactivex.rxjava3.core.Single<G> g)

    • resolveMany

      public static <A, B, C, D, E, F, G, H> io.reactivex.rxjava3.core.Single<org.javatuples.Octet<A,B,C,D,E,F,G,H>> resolveMany(@Nonnull io.reactivex.rxjava3.core.Single<A> a, @Nonnull io.reactivex.rxjava3.core.Single<B> b, @Nonnull io.reactivex.rxjava3.core.Single<C> c, @Nonnull io.reactivex.rxjava3.core.Single<D> d, @Nonnull io.reactivex.rxjava3.core.Single<E> e, @Nonnull io.reactivex.rxjava3.core.Single<F> f, @Nonnull io.reactivex.rxjava3.core.Single<G> g, @Nonnull io.reactivex.rxjava3.core.Single<H> h)

    • resolveMany

      public static <A, B, C, D, E, F, G, H, I> io.reactivex.rxjava3.core.Single<org.javatuples.Ennead<A,B,C,D,E,F,G,H,I>> resolveMany(@Nonnull io.reactivex.rxjava3.core.Single<A> a, @Nonnull io.reactivex.rxjava3.core.Single<B> b, @Nonnull io.reactivex.rxjava3.core.Single<C> c, @Nonnull io.reactivex.rxjava3.core.Single<D> d, @Nonnull io.reactivex.rxjava3.core.Single<E> e, @Nonnull io.reactivex.rxjava3.core.Single<F> f, @Nonnull io.reactivex.rxjava3.core.Single<G> g, @Nonnull io.reactivex.rxjava3.core.Single<H> h, @Nonnull io.reactivex.rxjava3.core.Single<I> i)

    • resolveMany

      public static <A, B, C, D, E, F, G, H, I, J> io.reactivex.rxjava3.core.Single<org.javatuples.Decade<A,B,C,D,E,F,G,H,I,J>> resolveMany(@Nonnull io.reactivex.rxjava3.core.Single<A> a, @Nonnull io.reactivex.rxjava3.core.Single<B> b, @Nonnull io.reactivex.rxjava3.core.Single<C> c, @Nonnull io.reactivex.rxjava3.core.Single<D> d, @Nonnull io.reactivex.rxjava3.core.Single<E> e, @Nonnull io.reactivex.rxjava3.core.Single<F> f, @Nonnull io.reactivex.rxjava3.core.Single<G> g, @Nonnull io.reactivex.rxjava3.core.Single<H> h, @Nonnull io.reactivex.rxjava3.core.Single<I> i, @Nonnull io.reactivex.rxjava3.core.Single<J> j)