Packages

radish

0.10.0
0.16.0 0.15.0 0.14.0 0.13.0 0.12.0 0.11.0 0.10.0 0.9.0 0.8.0 0.7.0 0.6.0 0.5.1 0.5.0 0.4.1 0.4.0 0.3.0 0.2.0 0.1.0

A Gleam client for Valkey, KeyDB, Redis and other tools with compatible APIs

HexDocs

Current section

Files

Jump to
Readme
18 Versions
4 Dependencies
Dependants
Files
Activity
radish src radish@command@pub_sub.erl
Raw

src/radish@command@pub_sub.erl 

-module(radish@command@pub_sub).

-compile([no_auto_import, nowarn_unused_vars, nowarn_unused_function]).



-export([publish/2, subscribe/1, subscribe_to_patterns/1, unsubscribe/1, unsubscribe_from_all/0, unsubscribe_from_patterns/1, unsubscribe_from_all_patterns/0]).



-spec publish(binary(), binary()) -> bitstring().

publish(Channel, Message) ->

    _pipe = [<<"PUBLISH"/utf8>>, Channel, Message],

    radish@utils:prepare(_pipe).



-spec subscribe(list(binary())) -> bitstring().

subscribe(Channels) ->

    _pipe = [<<"SUBSCRIBE"/utf8>>],

    _pipe@1 = gleam@list:append(_pipe, Channels),

    radish@utils:prepare(_pipe@1).



-spec subscribe_to_patterns(list(binary())) -> bitstring().

subscribe_to_patterns(Patterns) ->

    _pipe = [<<"PSUBSCRIBE"/utf8>>],

    _pipe@1 = gleam@list:append(_pipe, Patterns),

    radish@utils:prepare(_pipe@1).



-spec unsubscribe(list(binary())) -> bitstring().

unsubscribe(Channels) ->

    _pipe = [<<"UNSUBSCRIBE"/utf8>>],

    _pipe@1 = gleam@list:append(_pipe, Channels),

    radish@utils:prepare(_pipe@1).



-spec unsubscribe_from_all() -> bitstring().

unsubscribe_from_all() ->

    _pipe = [<<"UNSUBSCRIBE"/utf8>>],

    radish@utils:prepare(_pipe).



-spec unsubscribe_from_patterns(list(binary())) -> bitstring().

unsubscribe_from_patterns(Patterns) ->

    _pipe = [<<"PUNSUBSCRIBE"/utf8>>],

    _pipe@1 = gleam@list:append(_pipe, Patterns),

    radish@utils:prepare(_pipe@1).



-spec unsubscribe_from_all_patterns() -> bitstring().

unsubscribe_from_all_patterns() ->

    _pipe = [<<"PUNSUBSCRIBE"/utf8>>],

    radish@utils:prepare(_pipe).