streamSignalContainer<T, Arg> function

SignalContainer<AsyncState<T>, Arg, StreamSignal<T>> streamSignalContainer<T, Arg>(
  1. StreamSignal<T> create(
    1. Arg
    ), {
  2. bool cache = false,
  3. void onEvict(
    1. Arg key,
    2. StreamSignal<T> signal
    )?,
})

Create a signal container for StreamSignals based on args.

final container = streamSignalContainer<Message, int>((roomId) {
  return streamSignal(() => listenToRoom(roomId));
});

Implementation

SignalContainer<AsyncState<T>, Arg, StreamSignal<T>>
    streamSignalContainer<T, Arg>(
  StreamSignal<T> Function(Arg) create, {
  bool cache = false,
  void Function(Arg key, StreamSignal<T> signal)? onEvict,
}) {
  return SignalContainer<AsyncState<T>, Arg, StreamSignal<T>>(
    create,
    cache: cache,
    onEvict: onEvict,
  );
}