Module rabbit_control_misc

await_emitters_termination(Pids::[pid()]) -> ok

emitting_map(AggregatorPid::pid(), Ref::reference(), Fun::function(), List::list()) -> ok

emitting_map(AggregatorPid::pid(), Ref::reference(), Fun::function(), List::list(), X5::atom()) -> ok

emitting_map_with_exit_handler(AggregatorPid::pid(), Ref::reference(), Fun::function(), List::list()) -> ok

emitting_map_with_exit_handler(AggregatorPid::pid(), Ref::reference(), Fun::function(), List::list(), X5::continue) -> ok

print_cmd_result(X1::atom(), Result::term()) -> ok

spawn_emitter_caller(Node::node(), Mod::module(), Fun::atom(), Args::[term()], Ref::reference(), Pid::pid(), Timeout::timeout()) -> ok

wait_for_info_messages(Pid::pid(), Ref::reference(), Fun::fold_fun(), InitialAcc, Timeout::timeout(), ChunkCount::non_neg_integer()) -> OK | Err

• InitialAcc = term()
• Acc = term()
• OK = {ok, Acc}
• Err = {error, term()}