#Why isn't stop stopping this observable in v5?

1 messages · Page 1 of 1 (latest)

frosty marsh
#
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

frosty marsh
#

calling with stop(context.broadcastRef) as broadcastRef.stop() creates some weird infinite loop. after i stop the _state.status of the ref is still "active"

frosty marsh
#

I'll create a bug ticket Monday. Have a great weekend