rx/effect

Types

Effect

opaque </>

A runtime-agnostic asynchronous computation.

start receives a resolver and returns a cancellation function. The effect implementation may use a BEAM process, timer, socket, FFI callback, or any other mechanism. rx-gleam does not spawn work for the effect.

pub opaque type Effect(value, error)

Values

fail

</>

pub fn fail(reason: error) -> Effect(value, error)

map

</>

pub fn map(
  effect: Effect(a, error),
  transform: fn(a) -> b,
) -> Effect(b, error)

new

</>

pub fn new(
  start: fn(fn(Result(value, error)) -> Nil) -> fn() -> Nil,
) -> Effect(value, error)

pure

</>

pub fn pure(value: value) -> Effect(value, error)

run

</>

pub fn run(
  effect: Effect(value, error),
  resolve: fn(Result(value, error)) -> Nil,
) -> fn() -> Nil

to_observable

</>

pub fn to_observable(
  effect: Effect(value, error),
) -> rx.Observable(value, error)

Convert one effect result into an Observable.

The effect’s cancellation function becomes the Observable subscription teardown. Multiple or late resolver calls are still governed by the same runtime protocol as every other Observable producer.