prehistoric-systems/omnivore
1
0
Fork 0
mirror of https://github.com/omnivore-app/omnivore.git synced 2026-03-11 08:54:26 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Fix RSS

Browse source
This commit is contained in:
Thomas Rogers 2024-11-14 12:16:30 +01:00
parent 2d3971b715
commit 2b5572bfcd
1 changed files with 7 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
packages/discover/src/lib/store/feeds.ts
View file

@ -1,10 +1,12 @@
import { concatMap, mergeMap, Observable, tap } from 'rxjs'
import { concatMap, from, mergeMap, Observable, of, tap } from 'rxjs'
import { sqlClient } from './db'
import { OmnivoreFeed } from '../../types/Feeds'
import { fromPromise, fromArrayLike } from 'rxjs/internal/observable/innerFrom'
export const getRssFeeds$: Observable<OmnivoreFeed> = fromArrayLike(['restart']).pipe(
mergeMap(() =>
export const getRssFeeds$: Observable<OmnivoreFeed> = fromArrayLike([
'restart',
]).pipe(
concatMap(() =>
fromPromise(
(async (): Promise<OmnivoreFeed[]> => {
const { rows } = (await sqlClient.query(
@ -15,6 +17,6 @@ export const getRssFeeds$: Observable<OmnivoreFeed> = fromArrayLike(['restart'])
})()
)
),
tap(() => console.log('test')),
tap(console.log)
tap(console.log),
mergeMap((it: OmnivoreFeed[]) => fromArrayLike(it))
)