chore: Replace unwrap by expect.

Author: Hywan

crates/matrix-sdk-ui/src/timeline/builder.rs

@@ -164,7 +164,7 @@ impl TimelineBuilder {
         room.client().event_cache().subscribe()?;
 
         let (room_event_cache, event_cache_drop) = room.event_cache().await?;
-        let (_, event_subscriber) = room_event_cache.subscribe().await.unwrap();
+        let (_, event_subscriber) = room_event_cache.subscribe().await?;
 
         let is_room_encrypted = room
             .latest_encryption_state()
@@ -209,36 +209,40 @@ impl TimelineBuilder {
             .instrument(span)
         });
 
-        let thread_update_join_handle =
-            if let TimelineFocus::Thread { root_event_id: root } = &focus {
-                Some({
-                    let span = info_span!(
-                        parent: Span::none(),
-                        "thread_live_update_handler",
-                        room_id = ?room.room_id(),
-                        focus = focus.debug_string(),
-                        prefix = internal_id_prefix
-                    );
-                    span.follows_from(Span::current());
-
-                    // Note: must be done here *before* spawning the task, to avoid race conditions
-                    // with event cache updates happening in the background.
-                    let (_events, receiver) =
-                        room_event_cache.subscribe_to_thread(root.clone()).await.unwrap();
-
-                    spawn(
-                        thread_updates_task(
-                            receiver,
-                            room_event_cache.clone(),
-                            controller.clone(),
-                            root.clone(),
-                        )
-                        .instrument(span),
+        let thread_update_join_handle = if let TimelineFocus::Thread { root_event_id: root } =
+            &focus
+        {
+            Some({
+                let span = info_span!(
+                    parent: Span::none(),
+                    "thread_live_update_handler",
+                    room_id = ?room.room_id(),
+                    focus = focus.debug_string(),
+                    prefix = internal_id_prefix
+                );
+                span.follows_from(Span::current());
+
+                // Note: must be done here *before* spawning the task, to avoid race conditions
+                // with event cache updates happening in the background.
+                let (_events, receiver) =
+                        room_event_cache
+                            .subscribe_to_thread(root.clone())
+                            .await
+                            .expect("Failed to thread-subscribe to the `RoomEventCache` because of a store error");
+
+                spawn(
+                    thread_updates_task(
+                        receiver,
+                        room_event_cache.clone(),
+                        controller.clone(),
+                        root.clone(),
                     )
-                })
-            } else {
-                None
-            };
+                    .instrument(span),
+                )
+            })
+        } else {
+            None
+        };
 
         let local_echo_listener_handle = {
             let timeline_controller = controller.clone();

labs/multiverse/src/widgets/room_view/details/events.rs

@@ -28,7 +28,10 @@ impl Widget for &mut EventsView<'_> {
                 let events = tokio::task::block_in_place(|| {
                     Handle::current().block_on(async {
                         let (room_event_cache, _drop_handles) = room.event_cache().await.unwrap();
-                        room_event_cache.events().await.unwrap()
+                        room_event_cache
+                            .events()
+                            .await
+                            .expect("Failed to fetch the events because of a store error")
                     })
                 });