DiagnosticLogger::ChannelUtil
Class methods
batch(in_stream : Channel(T), size : Int32, interval : Time::Span) : Channel(Enumerable(T)) forall T
Sends batches of messages either every size messages received or every interval,
if a batch has not been sent within the last interval.
every(t : Time::Span, name = nil, terminate = Channel(Time).new, &block : -> T) : Channel(T) forall T
Source