class Cute::IntervalSink(T)

Overview

This sink has an internal timer. All collected data is only emitted once the timer triggers. If no data has been collected, the sink does not emit.

See Sink for documentation on the usage.

Direct Known Subclasses

Defined in:

cute/interval_sink.cr

Constructors

Instance Method Summary

Instance methods inherited from class Cute::Sink(T)

emit(data : Array(T)) : Nil emit, hit_count : Int32 hit_count, name : String name, new_channel : Tuple(Channel(Array(T)), Cute::ConnectionHandle) new_channel, notify(data : T) notify, on(&block : Proc(Array(T), Nil)) : Cute::ConnectionHandle
on(sink : Cute::Sink(U)) forall U on, stop! stop!

Constructor methods inherited from class Cute::Sink(T)

new new

Instance methods inherited from class Cute::Signal

disconnect(handler_hash)
disconnect disconnect, name : String | Nil name, wait wait

Constructor Detail

def self.new(interval : Time::Span) #

[View source]

Instance Method Detail

def interval : Time::Span #

Check interval


[View source]
def interval=(interval : Time::Span) #

Check interval


[View source]
def stop! #

Will eventually halt the internal timer fiber, releasing resources this sink occupies.


[View source]