diff --git a/flake.lock b/flake.lock
index 2be358a3b1e90a4ae95392a447e412e143f7f8a2..891a748260f6e8fd35ebd936ac715cb6f6c9c769 100644
--- a/flake.lock
+++ b/flake.lock
@@ -21,11 +21,11 @@
       },
       "locked": {
         "host": "git.c3pb.de",
-        "lastModified": 1628734583,
-        "narHash": "sha256-iLO9Ebh6Et9a+2thcn6Y4Ni9IzodPck+2J/J5q5MVVY=",
+        "lastModified": 1628788396,
+        "narHash": "sha256-5ROfsviLB9tD5PRRMY36hMO3MzF6jvKrmYlmz5eY06I=",
         "owner": "jens",
         "repo": "quasar",
-        "rev": "64c5b43d23951d0e539689847b683e844ea9d378",
+        "rev": "8a133f7d5e2965991c52355807facc5cee4a2b65",
         "type": "gitlab"
       },
       "original": {
diff --git a/src/Quasar/Network/Runtime/Observable.hs b/src/Quasar/Network/Runtime/Observable.hs
index 5d9181a0a46aae3d7e9927801e85147b93fa05ba..3a4758c7d6eb717a415c4d008eebcb69d0358620 100644
--- a/src/Quasar/Network/Runtime/Observable.hs
+++ b/src/Quasar/Network/Runtime/Observable.hs
@@ -43,7 +43,7 @@ newObservableStub startRetrieveRequest startObserveRequest = pure uncachedObserv
       -- TODO send updates about the connection status
       stream <- startObserveRequest
       streamSetHandler stream (callback . unpackObservableMessage)
-      pure $ synchronousDisposable $ streamClose stream
+      synchronousDisposable $ streamClose stream
     retrieveFn :: forall m. HasResourceManager m => m (Task v)
     retrieveFn = toTask <$> startRetrieveRequest