Start9/patch-db
2
0
Fork 0
mirror of https://github.com/Start9Labs/patch-db.git synced 2026-03-27 02:41:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

removes temps, massive refactor

Browse Source
This commit is contained in:
Matt Hill
2021-06-18 15:27:36 -06:00
parent 402754468c
commit b77571ebb0
19 changed files with 93 additions and 1135 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -1,7 +1,6 @@
import { BehaviorSubject, concat, from, Observable, of } from 'rxjs'
import { catchError, concatMap, delay, skip, switchMap, take, tap } from 'rxjs/operators'
import { Http } from '../patch-db'
import { UpdateReal } from '../sequence-store'
import { Http, Update } from '../types'
import { Source } from './source'
export type PollConfig = {
@@ -15,7 +14,7 @@ export class PollSource<T> implements Source<T> {
private readonly http: Http<T>,
) { }
watch$ (sequence$: Observable<number>): Observable<UpdateReal<T>> {
watch$ (sequence$: Observable<number>): Observable<Update<T>> {
console.log('POLL_SOURCE - watch$()')
const polling$ = new BehaviorSubject('')