src/rally_runtime@topics.erl

-module(rally_runtime@topics).
-compile([no_auto_import, nowarn_unused_vars, nowarn_unused_function, nowarn_nomatch, inline]).
-define(FILEPATH, "src/rally_runtime/topics.gleam").
-export([start/0, join/1, leave/1, members/1, broadcast/2, receive_frame/1]).

-file("src/rally_runtime/topics.gleam", 6).
-spec start() -> nil.
start() ->
    rally_runtime_topics_ffi:start().

-file("src/rally_runtime/topics.gleam", 11).
-spec join(binary()) -> nil.
join(_topic) ->
    rally_runtime_topics_ffi:join(_topic).

-file("src/rally_runtime/topics.gleam", 16).
-spec leave(binary()) -> nil.
leave(_topic) ->
    rally_runtime_topics_ffi:leave(_topic).

-file("src/rally_runtime/topics.gleam", 21).
-spec members(binary()) -> list(any()).
members(_topic) ->
    rally_runtime_topics_ffi:members(_topic).

-file("src/rally_runtime/topics.gleam", 26).
-spec broadcast(binary(), any()) -> nil.
broadcast(_topic, _frame) ->
    rally_runtime_topics_ffi:broadcast(_topic, _frame).

-file("src/rally_runtime/topics.gleam", 31).
-spec receive_frame(integer()) -> {ok, any()} | {error, nil}.
receive_frame(_timeout_ms) ->
    rally_runtime_topics_ffi:receive_frame(_timeout_ms).