radish/pub_sub

Types

pub type Next {
  Continue
  UnsubscribeFromAll
  UnsubscribeFrom(List(String))
}

Constructors

```
Continue
```
```
UnsubscribeFromAll
```
```
UnsubscribeFrom(List(String))
```

Functions

publish

</>

pub fn publish(
  client: Subject(Message),
  channel: String,
  message: String,
  timeout: Int,
) -> Result(Int, Error)

see here!

</>

pub fn subscribe(
  client: Subject(Message),
  channels: List(String),
  init_handler: fn(String, Int) -> Nil,
  message_handler: fn(String, String) -> Next,
  timeout: Int,
) -> Nil

see here! Also see here!

subscribe_to_patterns

</>

pub fn subscribe_to_patterns(
  client: Subject(Message),
  patterns: List(String),
  init_handler: fn(String, Int) -> Nil,
  message_handler: fn(String, String, String) -> Next,
  timeout: Int,
) -> Nil

see here! Also see here!