diff --git a/solar/src/actors/muxrpc/history_stream.rs b/solar/src/actors/muxrpc/history_stream.rs index 406f5d7..6d4e812 100644 --- a/solar/src/actors/muxrpc/history_stream.rs +++ b/solar/src/actors/muxrpc/history_stream.rs @@ -85,7 +85,7 @@ where self.recv_error_response(api, *req_no, err).await } // Handle a broker message. - RpcInput::Message(BrokerMessage::StoreKv(StoreKvEvent(ssb_id))) => { + RpcInput::Message(BrokerMessage::StoreKv(StoreKvEvent((ssb_id, _seq)))) => { // Notification from the key-value store indicating that // a new message has just been appended to the feed // identified by `ssb_id`.