| Overview |  |
pending_send() = {data, reference(), pid(), iodata(), boolean()}
stream_entry() = #{state := stream_state(), header_fragment := iodata(), header_len := non_neg_integer(), end_headers := boolean(), end_stream_seen := boolean(), headers := undefined | roadrunner_http:headers(), body := iolist(), body_len := non_neg_integer(), send_window := integer(), recv_window := non_neg_integer(), worker_pid := undefined | pid(), worker_ref := undefined | reference(), pending_sends := queue:queue(pending_send())}
stream_id() = pos_integer()
stream_state() = open | half_closed_remote | half_closed_local | closed
| enter/5 | |
| recv_more_hib/1 |
enter(Socket::roadrunner_transport:socket(), ProtoOpts::roadrunner_conn:proto_opts(), ListenerName::atom(), Peer::{inet:ip_address(), inet:port_number()} | undefined, StartMono::integer()) -> no_return()
recv_more_hib(Loop::#loop{socket = roadrunner_transport:socket(), proto_opts = roadrunner_conn:proto_opts(), listener_name = atom(), peer = {inet:ip_address(), inet:port_number()} | undefined, start_mono = integer(), scheme = http | https, msg_data = atom(), msg_closed = atom(), msg_error = atom(), buffer = binary(), hpack_dec = roadrunner_http2_hpack:context(), hpack_enc = roadrunner_http2_hpack:context(), last_stream_id = non_neg_integer(), req_id_buffer = binary(), conn_send_window = integer(), conn_recv_window = non_neg_integer(), recv_window_peak = pos_integer(), stream_recv_window_peak = pos_integer(), recv_window_threshold = pos_integer(), max_concurrent_streams = pos_integer(), max_header_block = pos_integer(), max_content_length = non_neg_integer(), max_header_list_size = pos_integer(), streams = #{stream_id() => stream_entry()}, worker_refs = #{reference() => stream_id()}, awaiting_continuation = undefined | stream_id(), peer_initial_window = integer(), draining = boolean()}) -> no_return()
Generated by EDoc