Start9/patch-db
2
0
Fork 0
mirror of https://github.com/Start9Labs/patch-db.git synced 2026-03-26 10:21:53 +00:00
Code Issues Packages Projects Releases Wiki Activity

start

Browse Source
This commit is contained in:
Matt Hill
2021-07-06 16:56:15 -06:00
committed by Aiden McClelland
parent a70d06644e
commit 98e213150f
4 changed files with 25 additions and 40 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
client/lib/source/poll-source.ts
View File

@@ -1,5 +1,5 @@
import { BehaviorSubject, concat, from, Observable, of } from 'rxjs'
import { concatMap, delay, map, skip, switchMap, take, tap } from 'rxjs/operators'
import { concatMap, delay, skip, switchMap, take, tap } from 'rxjs/operators'
import { Store } from '../store'
import { Http, Update } from '../types'
import { Source } from './source'
@@ -16,17 +16,13 @@ export class PollSource<T> implements Source<T> {
) { }
watch$ (store: Store<T>): Observable<Update<T>> {
const sequence$ = store.watchCache$()
.pipe(
map(cache => cache.sequence),
)
const polling$ = new BehaviorSubject('')
const updates$ = of('').pipe(
concatMap(_ => sequence$),
take(1),
const updates$ = of({ })
.pipe(
concatMap(_ => store.sequence$),
concatMap(seq => this.http.getRevisions(seq)),
take(1),
)
const delay$ = of([]).pipe(