Module orca_response

Data Types

buffer()

buffer() = iolist() | binary()

ctx()

ctx() = #orca_response_ctx{buf = buffer(), fsm = fsm(), packet_q = queue:queue(binary())}

fsm()

fsm() = #expect_seq_num{expected_seq_num = 0..255, expected_payload_size = non_neg_integer(), prev_payload = buffer()} | #expect_packet_len{expected_seq_num = 0..255, prev_payload = buffer()} | #reading_data{payload_acc = buffer(), bytes_left_to_read = non_neg_integer(), next_seq_num = undefined | 0..255}

Function Index

data_in/2
get_packet/1
new/0

Function Details

data_in/2

data_in(IOLOrBin::iolist() | binary(), Ctx0::ctx()) -> {ok, ctx()} | {error, Reason::term()}

get_packet/1

get_packet(Ctx0::ctx()) -> {ok, binary(), ctx()} | {error, not_ready}

new/0

new() -> ctx()


Generated by EDoc