Method expectSubscriptions

packages/test/src/assertions.ts:169–187

(actual: readonly TestSubscriptionLog[])

  }

  expectSubscriptions(actual: readonly TestSubscriptionLog[]): SubscriptionExpectation {
    const assertion: SubscriptionAssertion = {
      kind: 'subscriptions',
      actual,
      matched: false,
      evaluated: false,
    };
    this.#assertions.push(assertion);
    return {
      toBe: (marbles: string | readonly string[]): void => {
        this.#setMatcher(assertion);
        assertion.marbles = marbles;
        const diagrams = typeof marbles === 'string' ? [marbles] : marbles;
        assertion.expected = diagrams
          .map((diagram) => toSubscriptionLog(parseSubscriptionMarbles(diagram)))
          .filter((log) => log.subscribedFrame !== Infinity);
      },
    };
  }

  async evaluate(): Promise<void> {
    for (const assertion of this.#assertions) {