File tree Expand file tree Collapse file tree 2 files changed +4
-4
lines changed
crates/matrix-sdk-ui/src/spaces Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Original file line number Diff line number Diff line change 19
19
use eyeball:: { SharedObservable , Subscriber } ;
20
20
use futures_util:: pin_mut;
21
21
use matrix_sdk:: Client ;
22
- use matrix_sdk_common:: executor:: JoinHandle ;
22
+ use matrix_sdk_common:: executor:: { JoinHandle , spawn } ;
23
23
use ruma:: OwnedRoomId ;
24
24
use tokio_stream:: StreamExt ;
25
25
use tracing:: error;
@@ -53,7 +53,7 @@ impl SpaceService {
53
53
let joined_spaces_clone = joined_spaces. clone ( ) ;
54
54
let all_room_updates_receiver = client. subscribe_to_all_room_updates ( ) ;
55
55
56
- let handle = tokio :: spawn ( async move {
56
+ let handle = spawn ( async move {
57
57
pin_mut ! ( all_room_updates_receiver) ;
58
58
59
59
loop {
Original file line number Diff line number Diff line change @@ -17,7 +17,7 @@ use std::sync::Mutex;
17
17
use eyeball:: { SharedObservable , Subscriber } ;
18
18
use futures_util:: pin_mut;
19
19
use matrix_sdk:: { Client , Error , paginators:: PaginationToken } ;
20
- use matrix_sdk_common:: executor:: JoinHandle ;
20
+ use matrix_sdk_common:: executor:: { JoinHandle , spawn } ;
21
21
use ruma:: { OwnedRoomId , api:: client:: space:: get_hierarchy} ;
22
22
use tracing:: error;
23
23
@@ -56,7 +56,7 @@ impl SpaceServiceRoomList {
56
56
let rooms_clone = rooms. clone ( ) ;
57
57
let all_room_updates_receiver = client. subscribe_to_all_room_updates ( ) ;
58
58
59
- let handle = tokio :: spawn ( async move {
59
+ let handle = spawn ( async move {
60
60
pin_mut ! ( all_room_updates_receiver) ;
61
61
62
62
loop {
You can’t perform that action at this time.
0 commit comments