From a48031df7ca789c376646fe27b4228c8ae4d326e Mon Sep 17 00:00:00 2001
From: appflowy <annie@appflowy.io>
Date: Sun, 30 Jan 2022 10:33:05 +0800
Subject: [PATCH] return stream subscription

---
 frontend/app_flowy/packages/flowy_sdk/lib/rust_stream.dart | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/frontend/app_flowy/packages/flowy_sdk/lib/rust_stream.dart b/frontend/app_flowy/packages/flowy_sdk/lib/rust_stream.dart
index 633ebfe3b8..783a25ee8a 100644
--- a/frontend/app_flowy/packages/flowy_sdk/lib/rust_stream.dart
+++ b/frontend/app_flowy/packages/flowy_sdk/lib/rust_stream.dart
@@ -30,8 +30,8 @@ class RustStreamReceiver {
     return shared;
   }
 
-  static listen(void Function(SubscribeObject subject) callback) {
-    RustStreamReceiver.shared.observable.stream.listen(callback);
+  static StreamSubscription<SubscribeObject> listen(void Function(SubscribeObject subject) callback) {
+    return RustStreamReceiver.shared.observable.stream.listen(callback);
   }
 
   void streamCallback(Uint8List bytes) {