mirabelle.db.queue

IQueue

protocol

members

read-all!

(read-all! this action)

read all events from the queue, callling (action events) for each event.

write!

(write! this event)

push an event in the queue

make

(make queue)(make queue _)

Creates a new appender instance. Takes a queue to append to as argument. You can also call datafy on the appender to get associated data.