signalFromStream<T> method

BloomStreamSignal<T> signalFromStream<T>({
  1. required Stream<T> stream,
  2. required T initialValue,
})

Creates a reactive BloomStreamSignal whose value updates automatically from a Serverpod streaming stream.

Implementation

BloomStreamSignal<T> signalFromStream<T>({
  required Stream<T> stream,
  required T initialValue,
}) {
  final sig = signal<T>(initialValue);
  final sub = stream.listen(
    (data) => sig.value = data,
    onError: (err) => logger.error('BloomServerpodClient: Stream error: $err'),
  );
  return BloomStreamSignal<T>(signal: sig, subscription: sub);
}