return stream subscription

appflowy · appflowy · commit a48031df7ca7 · 2022-01-30T10:33:05.000+08:00
diff --git 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) {

Original file line number	Diff line number	Diff line change
`@@ -30,8 +30,8 @@ class RustStreamReceiver {`
`30`	`30`	`return shared;`
`31`	`31`	`}`
`32`	`32`
`33`		`- static listen(void Function(SubscribeObject subject) callback) {`
`34`		`- RustStreamReceiver.shared.observable.stream.listen(callback);`
	`33`	`+ static StreamSubscription<SubscribeObject> listen(void Function(SubscribeObject subject) callback) {`
	`34`	`+ return RustStreamReceiver.shared.observable.stream.listen(callback);`
`35`	`35`	`}`
`36`	`36`
`37`	`37`	`void streamCallback(Uint8List bytes) {`