broadcastRef: spawn(
fromObservable(() =>
defer(() => scheduled(broadcast(), asyncScheduler)).pipe(
repeat({ delay: () => timer(15_000) }),
tap((x) => console.log('broadcasting', x))
)
),
{
id: 'broadcaster',
}
),
I see broadcastRef is defined and I'm calling stop on it, but it's still sending the broadcasts being sent. I can create a sample in a bit