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