Converting event listeners into streams using the Effect library involves creating a stream that ...

const unsubProgress = await listen<ProgressState>(
  'export_logs_progress',
  action(({ payload }) => {
    this.chunks += payload.progress;
    this.state = payload.state;
  })
);

const unsubFinished = await listen<SaveLogsResult>(
  'export_logs_finished',
  ({ payload }) => {
    unsubFinished();
    unsubProgress();

    match(payload)
      .with({ _result: 'success' }, (matched) => {
        this.state = 'export_logs_finished';
        defer.rs(matched);
      })
      .with({ _result: 'failure' }, (matched) => {
        defer.rj(matched);
      })
      .exhaustive();
  }
);

const changes = Stream.async((emit) => {
  const unsubProgress = Effect.tryPromise(() =>
    listen<ProgressState>('export_logs_progress', ({ payload }) => {
      emit(Effect.succeed(Chunk.of(payload)));
    })
  );

  const unsubFinished = Effect.tryPromise(() =>
    listen<SaveLogsResult>('export_logs_finished', () => {
      emit(Effect.fail(Option.none()));
    })
  );
});