static <A, B> AutoCloseable dm_vmBus_onMessages_q(Cl<S> messages, IVF2<A, B> onMessage) {
  DynModule m = dm_current_mandatory();
  ret combineAutoCloseables(map(messages, msg ->
    dm_vmBus_onMessage_q(msg, onMessage)));
}