Packages

spoke_core

1.0.0
1.0.1 1.0.0

Purely functional core logic for an MQTT 3.1.1 client, using drift.

HexDocs

Current section

Files

Jump to
Readme
2 Versions
4 Dependencies
Dependants
Files
Activity
spoke_core include spoke@core_State.hrl
Raw

include/spoke@core_State.hrl 

-record(state, {

    options :: spoke@core:options(),

    session :: spoke@core@internal@session:session(),

    connection :: spoke@core:connection_state(),

    pending_subs :: gleam@dict:dict(integer(), spoke@core:pending_subscription()),

    pending_unsubs :: gleam@dict:dict(integer(), spoke@core:pending_unsubscribe()),

    send_ping_timer :: gleam@option:option(drift@internal@timer:timer()),

    ping_resp_timer :: gleam@option:option(drift@internal@timer:timer()),

    connect_timer :: gleam@option:option(drift@internal@timer:timer()),

    update_listeners :: gleam@set:set(drift:effect(spoke@mqtt:update())),

    publish_completion_listeners :: gleam@dict:dict(drift:effect({ok, nil} |

        {error, spoke@mqtt:operation_error()}), drift@internal@timer:timer())

}).