From ebbb347128a40bb3250c86c2e4cb05d6c1949a4f Mon Sep 17 00:00:00 2001
From: Matt Hill <matthewonthemoon@gmail.com>
Date: Wed, 10 Aug 2022 15:51:11 -0600
Subject: [PATCH] timeout on initial connect only

---
 client/lib/source/poll-source.ts | 13 ++-----------
 client/lib/source/ws-source.ts   |  2 +-
 2 files changed, 3 insertions(+), 12 deletions(-)

diff --git a/client/lib/source/poll-source.ts b/client/lib/source/poll-source.ts
index 39783b2..3bf3423 100644
--- a/client/lib/source/poll-source.ts
+++ b/client/lib/source/poll-source.ts
@@ -1,14 +1,5 @@
-import {
-  BehaviorSubject,
-  concat,
-  from,
-  ignoreElements,
-  Observable,
-  of,
-  repeatWhen,
-  timer,
-} from 'rxjs'
-import { concatMap, map, switchMap, take, tap } from 'rxjs/operators'
+import { from, Observable, of, repeatWhen, timer } from 'rxjs'
+import { concatMap, map, take } from 'rxjs/operators'
 import { Store } from '../store'
 import { Http, Update } from '../types'
 import { Source } from './source'
diff --git a/client/lib/source/ws-source.ts b/client/lib/source/ws-source.ts
index cd1a4f7..5ae027a 100644
--- a/client/lib/source/ws-source.ts
+++ b/client/lib/source/ws-source.ts
@@ -18,7 +18,7 @@ export class WebsocketSource<T> implements Source<T> {
       },
     })
 
-    return stream$.pipe(timeout(60000))
+    return stream$.pipe(timeout({ first: 60000 }))
   }
 }