All files / test/persistence util.ts

1
2
3
4
5
6
7
8
9
10
 
 
 
2x
23x
 
23x
 
 
 
import { Observable } from 'rxjs';
 
// eslint-disable-next-line @typescript-eslint/no-explicit-any
export const assertCompletesWithoutEmitting = async (observable: Observable<any>) =>
  expect(
    await new Promise((resolve, reject) =>
      observable.subscribe({ complete: () => resolve(true), error: reject, next: reject })
    )
  ).toBe(true);