Package org.jsignal.rx.scheduled

Class Schedules

java.lang.Object

org.jsignal.rx.scheduled.Schedules

public class Schedules
extends Object

Constructor Summary

Constructors

Constructor	Description
Schedules()

Method Summary

Modifier and Type	Method	Description
static ScheduledFactory	createDebounceFactory(ScheduledExecutorService executor)
static ScheduledFactory	createThrottledFactory(ScheduledExecutorService executor)
static <T> Scheduled<T>	debounce(Consumer<T> inner, long wait, TimeUnit unit)
static <T> Scheduled<T>	leading(ScheduledFactory schedule, Consumer<T> callback, long wait, TimeUnit unit)
static <T> Scheduled<T>	throttle(Consumer<T> callback, long wait, TimeUnit unit)

Methods inherited from class java.lang.Object

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

Constructor Details

Schedules

public Schedules()

Method Details

createDebounceFactory

public static ScheduledFactory createDebounceFactory(ScheduledExecutorService executor)

debounce

public static <T> Scheduled<T> debounce(Consumer<T> inner,
 long wait,
 TimeUnit unit)

createThrottledFactory

public static ScheduledFactory createThrottledFactory(ScheduledExecutorService executor)

throttle

public static <T> Scheduled<T> throttle(Consumer<T> callback,
 long wait,
 TimeUnit unit)

leading

public static <T> Scheduled<T> leading(ScheduledFactory schedule,
 Consumer<T> callback,
 long wait,
 TimeUnit unit)