emqtt_quic_stream (emqtt v1.15.1)

View Source

Summary

Types

cb_data/0
cb_ret/0
conf_handle/0
connection_handle/0
global_handle/0
handle/0
listener_handle/0
reg_handle/0
stream_closed_props/0
stream_handle/0

Functions

handle_call(Stream, Request, Opts, S)
handle_stream_data(Stream, Bin, Flags, S)
init_handoff(Stream, StreamOpts, Conn, Flags)
new_stream(Stream, _, Conn)
passive(Stream, _, S)
peer_accepted(Stream, _, S)
peer_receive_aborted(Stream, ErrorCode, S)
peer_send_aborted(Stream, ErrorCode, S)
peer_send_shutdown(Stream, _, S)
send_complete(Stream, IsCanceled, S)
send_shutdown_complete(Stream, IsGraceful, S)
start_completed(Stream, Prop, S)
stream_closed(CtrlStream, P, S)

Types

cb_data/0

-type cb_data() :: emqtt_quic:cb_data().

cb_ret/0

-type cb_ret() :: gen_statem:handle_event_result().

conf_handle/0

-type conf_handle() :: reference().

connection_handle/0

-type connection_handle() :: reference().

global_handle/0

-type global_handle() :: quic_global.

handle/0

-type handle() ::
          global_handle() |
          listener_handle() |
          connection_handle() |
          stream_handle() |
          conf_handle() |
          reg_handle().

listener_handle/0

-type listener_handle() :: reference().

reg_handle/0

-type reg_handle() :: reference().

stream_closed_props/0

-type stream_closed_props() :: map().

stream_handle/0

-type stream_handle() :: reference().

Functions

handle_call(Stream, Request, Opts, S)

handle_stream_data(Stream, Bin, Flags, S)

-spec handle_stream_data(stream_handle(), binary(), quicer:recv_data_props(), cb_data()) -> cb_ret().

init_handoff(Stream, StreamOpts, Conn, Flags)

-spec init_handoff(stream_handle(), #{}, quicer:connection_handle(), #{}) -> cb_ret().

new_stream(Stream, _, Conn)

-spec new_stream(stream_handle(), quicer:new_stream_props(), connection_handle()) -> cb_ret().

passive(Stream, _, S)

-spec passive(stream_handle(), undefined, cb_data()) -> cb_ret().

peer_accepted(Stream, _, S)

-spec peer_accepted(stream_handle(), undefined, cb_data()) -> cb_ret().

peer_receive_aborted(Stream, ErrorCode, S)

-spec peer_receive_aborted(stream_handle(), non_neg_integer(), cb_data()) -> cb_ret().

peer_send_aborted(Stream, ErrorCode, S)

-spec peer_send_aborted(stream_handle(), non_neg_integer(), cb_data()) -> cb_ret().

peer_send_shutdown(Stream, _, S)

-spec peer_send_shutdown(stream_handle(), undefined, cb_data()) -> cb_ret().

send_complete(Stream, IsCanceled, S)

-spec send_complete(stream_handle(), boolean(), cb_data()) -> cb_ret().

send_shutdown_complete(Stream, IsGraceful, S)

-spec send_shutdown_complete(stream_handle(), boolean(), cb_data()) -> cb_ret().

start_completed(Stream, Prop, S)

-spec start_completed(stream_handle(), quicer:stream_start_completed_props(), cb_data()) -> cb_ret().

stream_closed(CtrlStream, P, S)

-spec stream_closed(stream_handle(), stream_closed_props(), cb_data()) -> cb_ret().