Simple PubSub for gleam

Simple PubSub for gleam, based on process groups.

Usage

Add this library to your Gleam project

gleam add simple_pubsub

And use it in your project

Example

import simple_pubsub as ps
import process_groups
import gleam/erlang/process

// Messages we want to send over the PubSub
type PubSubMessage{
    PubSubMessage
}

pub fn main() {
    // start process groups, needed for pubsub
    process_groups.start_link()

    // create a pubsub
    let pubsub = ps.new_pubsub()

    // subscribe, normally you would subscribe another process than this one
    let subscription = ps.subscribe(pubsub, process.self())

    // broadcast a message
    ps.broadcast(pubsub, PubSubMessage)

    // receive the message
    let assert Ok(PubSubMessage) = ps.receive(subscription, 100)
}

Development

gleam run   # Run the project
gleam test  # Run the tests
gleam shell # Run an Erlang shell