Package org.jsignal.rx

Class RxUtil

java.lang.Object

org.jsignal.rx.RxUtil

public class RxUtil
extends Object

Method Summary

Modifier and Type	Method	Description
static void	batch(Runnable inner)
static <T, U> Computed<List<U>>	createIndexed(Supplier<? extends List<T>> list, BiFunction<Supplier<T>,Integer,U> map)
static <T, U> Computed<List<U>>	createMapped(Supplier<? extends List<T>> list, BiFunction<T,Supplier<Integer>,U> map)
static <T> Supplier<T>	createMemo(Supplier<SignalLike<T>> signal, Supplier<T> supplier)
static <T> Supplier<T>	createMemo(Supplier<T> supplier)
static <T> void	drain(Queue<T> from)
static <T> void	drain(Queue<T> from, Queue<T> to)
static void	ignore(Runnable inner)
static <T> T	ignore(Supplier<T> signal)
static <T, V> Supplier<V>	maybeConstant(Supplier<T> supplier, Function<T,V> func)
static <T> Supplier<T>	maybeRemoveComputed(Computed<T> computed)
static <T> Supplier<T>	memo(Supplier<T> supplier)
static <T> Runnable	on(Supplier<T> dep, Runnable effect)
static <T> Runnable	on(Supplier<T> dep, BiConsumer<T,T> inner)
static <T> Runnable	on(Supplier<T> dep, Consumer<T> inner)
static <T, U> Supplier<U>	on(Supplier<T> dep, Function<T,U> inner)
static <T, U> Function<U,U>	on(Supplier<T> dep, OnFn<T,U> inner)	Sometimes it is useful to explicitly track a dependency instead of using automatic tracking.
static <T> Runnable	onDefer(Supplier<T> dep, Runnable inner)
static <T> Runnable	onDefer(Supplier<T> dep, BiConsumer<T,T> inner)
static <T> Runnable	onDefer(Supplier<T> dep, Consumer<T> effect)
static <T, U> Function<U,U>	onDefer(Supplier<T> dep, OnFn<T,U> effect)
static void	run(Runnable runnable)
static <T> T	run(Supplier<T> supplier)
static <T> Consumer<T>	toConsumer(Runnable runnable)
static <T> Function<T,T>	toFunction(Supplier<T> supplier)
static <T> Function<T,T>	toFunction(T value)
static <T> OnFn<T,Void>	toOnFn(BiConsumer<T,T> consumer)
static Runnable	toRunnable(BiConsumer<Void,Void> consumer)
static Runnable	toRunnable(Consumer<Void> consumer)
static Runnable	toRunnable(Function<Void,Void> consumer)
static Supplier<Void>	toSupplier(Runnable runnable)

Methods inherited from class java.lang.Object

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

Method Details

memo

public static <T> Supplier<T> memo(Supplier<T> supplier)

createMemo

public static <T> Supplier<T> createMemo(Supplier<T> supplier)

createMemo

public static <T> Supplier<T> createMemo(Supplier<SignalLike<T>> signal,
 Supplier<T> supplier)

maybeRemoveComputed

public static <T> Supplier<T> maybeRemoveComputed(Computed<T> computed)

maybeConstant

public static <T,
V> Supplier<V> maybeConstant(Supplier<T> supplier,
 Function<T,V> func)

batch

public static void batch(Runnable inner)

ignore

public static void ignore(Runnable inner)

ignore

public static <T> T ignore(Supplier<T> signal)

on

public static <T> Runnable on(Supplier<T> dep,
 Runnable effect)

on

public static <T> Runnable on(Supplier<T> dep,
 Consumer<T> inner)

on

public static <T,
U> Supplier<U> on(Supplier<T> dep,
 Function<T,U> inner)

on

public static <T> Runnable on(Supplier<T> dep,
 BiConsumer<T,T> inner)

on

public static <T,
U> Function<U,U> on(Supplier<T> dep,
 OnFn<T,U> inner)

Sometimes it is useful to explicitly track a dependency instead of using automatic tracking. The primary added benefit is it makes it easy to get the previous value when reacting to a change.

onDefer

public static <T> Runnable onDefer(Supplier<T> dep,
 Runnable inner)

onDefer

public static <T> Runnable onDefer(Supplier<T> dep,
 Consumer<T> effect)

onDefer

public static <T> Runnable onDefer(Supplier<T> dep,
 BiConsumer<T,T> inner)

onDefer

public static <T,
U> Function<U,U> onDefer(Supplier<T> dep,
 OnFn<T,U> effect)

toRunnable

public static Runnable toRunnable(Consumer<Void> consumer)

toRunnable

public static Runnable toRunnable(BiConsumer<Void,Void> consumer)

toRunnable

public static Runnable toRunnable(Function<Void,Void> consumer)

toSupplier

public static Supplier<Void> toSupplier(Runnable runnable)

toConsumer

public static <T> Consumer<T> toConsumer(Runnable runnable)

toFunction

public static <T> Function<T,T> toFunction(Supplier<T> supplier)

toFunction

public static <T> Function<T,T> toFunction(T value)

toOnFn

public static <T> OnFn<T,Void> toOnFn(BiConsumer<T,T> consumer)

run

public static <T> T run(Supplier<T> supplier)

run

public static void run(Runnable runnable)

createMapped

public static <T,
U> Computed<List<U>> createMapped(Supplier<? extends List<T>> list,
 BiFunction<T,Supplier<Integer>,U> map)

createIndexed

public static <T,
U> Computed<List<U>> createIndexed(Supplier<? extends List<T>> list,
 BiFunction<Supplier<T>,Integer,U> map)

drain

public static <T> void drain(Queue<T> from,
 Queue<T> to)

drain

public static <T> void drain(Queue<T> from)