Module roadrunner_ws_session

Behaviours: gen_statem.

Function Index

awaiting_socket/3
callback_mode/0
frame_loop/3
init/1
run/6
terminate/3
unmask_slice/3

Function Details

awaiting_socket/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/0

callback_mode() -> gen_statem:callback_mode_result()

frame_loop/3

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/1

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/6

run(Socket::roadrunner_transport:socket(), Req::roadrunner_req:request(), Mod::module(), State::term(), Buffered::binary(), ProtoOpts::roadrunner_conn:proto_opts()) -> ok

terminate/3

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/3

unmask_slice(Slice::binary(), X2::binary(), Offset::non_neg_integer()) -> binary()


Generated by EDoc