'->
('-> '#Uq_engines.engine) Stream.t ->
Unixqueue.event_system -> ['a] Uq_engines.engine