reactive_signal

A Gleam library for cross-process reactive signal

[!WARNING] This is an experimental library, so breaking changes are actively made

gleam add reactive_signal

import reactive_signal

pub fn main() {
  let new_listener = fn(logger) {
    fn(value) { process.send(logger, "Listened:" <> int.to_string(value)) }
  }

  let new_app = fn(logger: Subject(String)) {
    let #(sig, chn) = signal.new(0)
    let #(sig2, chn2) = signal.new(0)
    let sig3 = {
      use x <- signal.chain(sig)
      use y <- signal.chain(sig2)
      signal.pure(x + y)
    }
    signal.subscribe(sig3, new_listener(logger))
    channel.write(chn, 1)
    channel.write(chn2, 1)
  }

  let logger = process.new_subject()
  new_app(logger)

  process.receive(logger, 10)
  |> should.equal(Ok("Listened:0"))

  process.receive(logger, 10)
  |> should.equal(Ok("Listened:1"))

  process.receive(logger, 10)
  |> should.equal(Ok("Listened:2"))
}

Further documentation can be found at https://hexdocs.pm/reactive_signal.

Development

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