module

ArrJanitor::LogConsumer

Drains LogEvents off the channel on the main fiber and emits each one via Crystal's Log, so console output stays ordered across worker threads.

Class methods

drain(channel : Channel(LogEvent)) : Nil

Receives events until the channel is closed, emitting each via Log.for(source).