collect_object(X1, X2) -> any()
handle_event(Event, St) -> any()
init(X1) -> any()
init_stream(Parent, Owner, StreamRef, Db, Options) -> any()
maybe_continue(State) -> any()
maybe_continue_decoding(State) -> any()
start_link(Owner, StreamRef, Db, Options) -> any()
system_code_change(Misc, X2, X3, X4) -> any()
system_continue(X1, X2, X3) -> any()
system_terminate(Reason::any(), X2::term(), X3::term(), State::term()) -> no_return()
wait_reconnect(State) -> any()
wait_results(X1, St) -> any()
wait_results1(X1, X2) -> any()