class

CRE::Engine::Subscribers::AuditSubscriber

Inherits Reference < Object

Constructors

new(bus : EventBus, log : Audit::AuditLog, actor : String = "system")
Source

Instance methods

await_drain(timeout_span : Time::Span = 2.seconds) : Bool

Block until either the subscriber receives ShutdownRequested (i.e. has drained everything published before the shutdown signal) or the timeout elapses. Lets engine.stop deterministically wait instead of sleeping for a magic 50ms.

Source
start
Source
stop
Source