Module rabbit_writer

enter_mainloop(Identity, State) -> any()

flush(W::pid()) -> ok

internal_send_command(Sock::rabbit_net:socket(), Channel::rabbit_channel:channel_number(), MethodRecord::rabbit_framing:amqp_method_record(), Protocol::rabbit_types:protocol()) -> ok

internal_send_command(Sock::rabbit_net:socket(), Channel::rabbit_channel:channel_number(), MethodRecord::rabbit_framing:amqp_method_record(), Content::rabbit_types:content(), FrameMax::non_neg_integer(), Protocol::rabbit_types:protocol()) -> ok

mainloop(Deb, State) -> any()

mainloop1(Deb, State) -> any()

maybe_gc_large_msg(Content::rabbit_types:content() | rabbit_types:message()) -> non_neg_integer()

maybe_gc_large_msg(Content::rabbit_types:content() | rabbit_types:message(), GCThreshold::undefined | non_neg_integer()) -> undefined | non_neg_integer()

msg_size(Content::rabbit_types:content() | rabbit_types:message()) -> non_neg_integer()

send_command(W::pid(), MethodRecord::rabbit_framing:amqp_method_record()) -> ok

send_command(W::pid(), MethodRecord::rabbit_framing:amqp_method_record(), Content::rabbit_types:content()) -> ok

send_command_and_notify(W::pid(), Q::pid(), ChPid::pid(), MethodRecord::rabbit_framing:amqp_method_record()) -> ok

send_command_and_notify(W::pid(), Q::pid(), ChPid::pid(), MethodRecord::rabbit_framing:amqp_method_record(), Content::rabbit_types:content()) -> ok

send_command_flow(W::pid(), MethodRecord::rabbit_framing:amqp_method_record()) -> ok

send_command_flow(W::pid(), MethodRecord::rabbit_framing:amqp_method_record(), Content::rabbit_types:content()) -> ok

send_command_sync(W::pid(), MethodRecord::rabbit_framing:amqp_method_record()) -> ok

send_command_sync(W::pid(), MethodRecord::rabbit_framing:amqp_method_record(), Content::rabbit_types:content()) -> ok

start(Sock::rabbit_net:socket(), Channel::rabbit_channel:channel_number(), FrameMax::non_neg_integer(), Protocol::rabbit_types:protocol(), ReaderPid::pid(), Identity::rabbit_types:proc_name()) -> rabbit_types:ok(pid())

start(Sock::rabbit_net:socket(), Channel::rabbit_channel:channel_number(), FrameMax::non_neg_integer(), Protocol::rabbit_types:protocol(), ReaderPid::pid(), Identity::rabbit_types:proc_name(), ReaderWantsStats::boolean()) -> rabbit_types:ok(pid())

start(Sock::rabbit_net:socket(), Channel::rabbit_channel:channel_number(), FrameMax::non_neg_integer(), Protocol::rabbit_types:protocol(), ReaderPid::pid(), Identity::rabbit_types:proc_name(), ReaderWantsStats::boolean(), GCThreshold::undefined | non_neg_integer()) -> rabbit_types:ok(pid())

start_link(Sock::rabbit_net:socket(), Channel::rabbit_channel:channel_number(), FrameMax::non_neg_integer(), Protocol::rabbit_types:protocol(), ReaderPid::pid(), Identity::rabbit_types:proc_name()) -> rabbit_types:ok(pid())

start_link(Sock::rabbit_net:socket(), Channel::rabbit_channel:channel_number(), FrameMax::non_neg_integer(), Protocol::rabbit_types:protocol(), ReaderPid::pid(), Identity::rabbit_types:proc_name(), ReaderWantsStats::boolean()) -> rabbit_types:ok(pid())

start_link(Sock::rabbit_net:socket(), Channel::rabbit_channel:channel_number(), FrameMax::non_neg_integer(), Protocol::rabbit_types:protocol(), ReaderPid::pid(), Identity::rabbit_types:proc_name(), ReaderWantsStats::boolean(), GCThreshold::undefined | non_neg_integer()) -> rabbit_types:ok(pid())

system_code_change(Misc::term(), Module::term(), OldVsn::term(), Extra::term()) -> {ok, term()}

system_continue(Parent::term(), Deb::term(), Wstate::#wstate{}) -> any()

system_terminate(Reason::term(), Parent::term(), Deb::term(), State::term()) -> no_return()