Search results

debounce :: forall a. Time -> Signal a -> Signal a

Takes a signal and a time value, and creates a signal which waits to yield the next result until the specified amount of time has elapsed. It then yields only the newest value from that period. New events during the debounce period reset the delay.

debounce :: forall a. Milliseconds -> Event a -> Event a

On each event, ignore subsequent events for a given number of milliseconds.

debounce :: forall a. Milliseconds -> Event a -> Event a

On each event, ignore subsequent events for a given number of milliseconds.

debounce :: forall m a. Monad m => Alt m => MonadAff m => Number -> a -> (a -> m a) -> SignalT m a

debounce :: forall a. (a -> Observable Int) -> Observable a -> Observable a

It's like debounceTime, but the time span of emission silence is determined by a second ObservableImpl. Allows for a variable debounce rate.

debounce :: forall a. (a -> Effect Unit) -> Int -> Debounce

debounce :: forall a. (a -> Effect Unit) -> Int -> Debounce

debounce :: forall a. Int -> Event a -> Event a

debounce :: forall duration a output input state env. Duration duration => duration -> (input -> Maybe (Saga' env state input output a)) -> Saga' env state input output a

debounce :: forall a. Int -> Observable a -> Observable a

debounce :: forall a. (a -> Observable Int) -> Observable a -> Observable a

It's like debounceTime, but the time span of emission silence is determined by a second ObservableImpl. Allows for a variable debounce rate.

debounce :: forall a. AsyncSubject a -> (a -> AsyncSubject Int) -> AsyncSubject a

It's like debounceTime, but the time span of emission silence is determined by a second AsyncSubject. Allows for a variable debounce rate.

debounce :: forall a. BehaviorSubject a -> (a -> BehaviorSubject Int) -> BehaviorSubject a

It's like debounceTime, but the time span of emission silence is determined by a second BehaviorSubject. Allows for a variable debounce rate.

debounce :: forall a. Observable a -> (a -> Observable Int) -> Observable a

It's like debounceTime, but the time span of emission silence is determined by a second Observable. Allows for a variable debounce rate.

debounce :: forall a. ReplaySubject a -> (a -> ReplaySubject Int) -> ReplaySubject a

It's like debounceTime, but the time span of emission silence is determined by a second ReplaySubject. Allows for a variable debounce rate.

debounce :: forall a rw. Milliseconds -> Signal (read :: READ | rw) a -> Effect (Signal (read :: READ, write :: WRITE) a)

Re-emits changes to the input signal, only if the change occurred after the time limit.

debounceWith :: forall a b. (Event a -> Event { period :: Milliseconds, value :: b }) -> Event a -> Event b

Provided an input event and transformation, block the input event for the duration of the specified period on each output.

debounceWith :: forall b a. (Event a -> Event { period :: Milliseconds, value :: b }) -> Event a -> Event b

Provided an input event and transformation, block the input event for the duration of the specified period on each output.

debounceTime :: forall f a. Functor f => Int -> ObservableT f a -> ObservableT f a

It's like delay, but passes only the most recent value from each burst of emissions.

debounceTime :: forall f a. Functor f => Int -> ObservableT f a -> ObservableT f a

It's like delay, but passes only the most recent value from each burst of emissions.

debounceTime :: forall a. Int -> AsyncSubject a -> AsyncSubject a

It's like delay, but passes only the most recent value from each burst of emissions.

debounceTime :: forall a. Int -> BehaviorSubject a -> BehaviorSubject a

It's like delay, but passes only the most recent value from each burst of emissions.

debounceTime :: forall a. Int -> Observable a -> Observable a

It's like delay, but passes only the most recent value from each burst of emissions.

debounceTime :: forall a. Int -> ReplaySubject a -> ReplaySubject a

It's like delay, but passes only the most recent value from each burst of emissions.

debounceStatic :: forall queue a. QueueExtra queue => Milliseconds -> queue (read :: READ) a -> Aff { input :: queue (write :: WRITE) a, writer :: Fiber Unit }

messages submitted before debounceStatic's time period will be dropped