Remove unnecessary Result wrapper

src/alis.rs

@@ -19,13 +19,12 @@ struct EventSerializer(u64);
 
 pub async fn stream<S: Stream<Item = Result<Event, BroadcastStreamRecvError>>>(
     stream: S,
-) -> Result<impl Stream<Item = Result<Vec<u8>, BroadcastStreamRecvError>>> {
+) -> impl Stream<Item = Result<Vec<u8>, BroadcastStreamRecvError>> {
     let header = stream::once(future::ready(Ok(MAGIC_STRING.into())));
     let mut serializer = EventSerializer(0);
-
     let events = stream.map(move |event| event.map(|event| serializer.serialize_event(event)));
 
-    Ok(header.chain(events))
+    header.chain(events)
 }
 
 impl EventSerializer {

src/forwarder.rs

@@ -143,7 +143,7 @@ async fn event_stream(
     let stream = subscriber.subscribe().await?;
 
     let stream = alis::stream(stream)
-        .await?
+        .await
         .map(ws_result)
         .chain(futures_util::stream::once(future::ready(Ok(
             close_message(),

src/server.rs

@@ -122,7 +122,7 @@ async fn handle_socket(socket: WebSocket, subscriber: Subscriber) -> anyhow::Res
     let stream = subscriber.subscribe().await?;
 
     let result = alis::stream(stream)
-        .await?
+        .await
         .map(ws_result)
         .chain(futures_util::stream::once(future::ready(Ok(close_msg))))
         .forward(sink)