Behaviours: gen_statem.
| awaiting_socket/3 | |
| callback_mode/0 | |
| frame_loop/3 | |
| init/1 | |
| run/6 | |
| terminate/3 | |
| unmask_slice/3 |
awaiting_socket(X1::gen_statem:event_type(), Old::term(), Data::#data{socket = roadrunner_transport:socket(), buffer = binary(), mod = module(), mod_state = term(), ctx = map(), has_init = boolean(), has_handle_info = boolean(), has_handle_drain = boolean(), pmd_params = roadrunner_ws:permessage_deflate_params() | undefined, inflate_z = zlib:zstream() | undefined, deflate_z = zlib:zstream() | undefined, msg_acc = undefined | iodata(), msg_opcode = undefined | text | binary, msg_compressed = boolean(), max_frame_size = non_neg_integer(), max_message_size = non_neg_integer(), msg_size = non_neg_integer(), utf8_pending = binary(), frame_validated = non_neg_integer(), unmasked_buf = binary()}) -> gen_statem:event_handler_result(atom())
callback_mode() -> gen_statem:callback_mode_result()
frame_loop(X1::gen_statem:event_type(), Old::term(), Data::#data{socket = roadrunner_transport:socket(), buffer = binary(), mod = module(), mod_state = term(), ctx = map(), has_init = boolean(), has_handle_info = boolean(), has_handle_drain = boolean(), pmd_params = roadrunner_ws:permessage_deflate_params() | undefined, inflate_z = zlib:zstream() | undefined, deflate_z = zlib:zstream() | undefined, msg_acc = undefined | iodata(), msg_opcode = undefined | text | binary, msg_compressed = boolean(), max_frame_size = non_neg_integer(), max_message_size = non_neg_integer(), msg_size = non_neg_integer(), utf8_pending = binary(), frame_validated = non_neg_integer(), unmasked_buf = binary()}) -> gen_statem:event_handler_result(atom())
init(X1::{roadrunner_transport:socket(), module(), term(), map(), roadrunner_ws:negotiated(), binary(), roadrunner_conn:proto_opts()}) -> {ok, awaiting_socket, #data{socket = roadrunner_transport:socket(), buffer = binary(), mod = module(), mod_state = term(), ctx = map(), has_init = boolean(), has_handle_info = boolean(), has_handle_drain = boolean(), pmd_params = roadrunner_ws:permessage_deflate_params() | undefined, inflate_z = zlib:zstream() | undefined, deflate_z = zlib:zstream() | undefined, msg_acc = undefined | iodata(), msg_opcode = undefined | text | binary, msg_compressed = boolean(), max_frame_size = non_neg_integer(), max_message_size = non_neg_integer(), msg_size = non_neg_integer(), utf8_pending = binary(), frame_validated = non_neg_integer(), unmasked_buf = binary()}} | {stop, {bad_handler, module()}}
run(Socket::roadrunner_transport:socket(), Req::roadrunner_req:request(), Mod::module(), State::term(), Buffered::binary(), ProtoOpts::roadrunner_conn:proto_opts()) -> ok
terminate(Reason::term(), State::atom(), Data::#data{socket = roadrunner_transport:socket(), buffer = binary(), mod = module(), mod_state = term(), ctx = map(), has_init = boolean(), has_handle_info = boolean(), has_handle_drain = boolean(), pmd_params = roadrunner_ws:permessage_deflate_params() | undefined, inflate_z = zlib:zstream() | undefined, deflate_z = zlib:zstream() | undefined, msg_acc = undefined | iodata(), msg_opcode = undefined | text | binary, msg_compressed = boolean(), max_frame_size = non_neg_integer(), max_message_size = non_neg_integer(), msg_size = non_neg_integer(), utf8_pending = binary(), frame_validated = non_neg_integer(), unmasked_buf = binary()}) -> ok
unmask_slice(Slice::binary(), X2::binary(), Offset::non_neg_integer()) -> binary()
Generated by EDoc