Skip to content

Commit fb750a3

Browse files
committed
Skip the persisted input in stream_input
1 parent b7da524 commit fb750a3

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

lighthouse-client/src/lighthouse.rs

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -146,7 +146,10 @@ impl<S> Lighthouse<S>
146146
/// and parse `LegacyInputEvent`s from there.
147147
pub async fn stream_input(&self) -> Result<impl Stream<Item = Result<ServerMessage<InputEvent>>>> {
148148
let username = self.authentication.username.clone();
149-
self.stream(&["user".into(), username, "input".into()], ()).await
149+
Ok(
150+
self.stream(&["user".into(), username, "input".into()], ()).await?
151+
.skip(1) // Skip the persisted input (TODO: Should we handle this at the server level via some form of passthrough resources?)
152+
)
150153
}
151154

152155
/// Fetches lamp server metrics.

0 commit comments

Comments
 (0)