Class CounterComponent

libs/state/spec/rx-state.docs.spec.ts:21–38

  `,
})
export class CounterComponent {
  readonly increment = new Subject<void>();
  readonly decrement = new Subject<void>();

  private readonly state = rxState<{ count: number }>(({ connect, set }) => {
    set({ count: 0 });
    connect(
      'count',
      merge(
        this.increment.pipe(map(() => 1)),
        this.decrement.pipe(map(() => -1))
      ),
      ({ count }, slice) => count + slice
    );
  });

  readonly count$ = this.state.select('count');
}

describe('CounterComponent', () => {
  let fixture: ComponentFixture<CounterComponent>;