vladmiller

// Factory to generate payment streams
const getPayments$ = () => {
  const isLoading$ = new BehaviorSubject<boolean>(false)
  const error$ = new Subject<ApiError | null>()

  // Stream that holds currently actie DB
  const db$ = activeDB$.pipe(map(mapDB<AgentDB>))

  const baseCollection$ = db$.pipe(