Skip to content
This repository has been archived by the owner on Dec 18, 2024. It is now read-only.

Commit

Permalink
fi subscribe method for viss
Browse files Browse the repository at this point in the history
  • Loading branch information
rafaeling committed Feb 9, 2024
1 parent eb6160e commit eb93ef5
Showing 1 changed file with 9 additions and 1 deletion.
10 changes: 9 additions & 1 deletion kuksa_databroker/databroker/src/viss/v2/server.rs
Original file line number Diff line number Diff line change
Expand Up @@ -253,7 +253,15 @@ impl Viss for Server {
let Some(entries) = broker
.get_id_by_path(request.path.as_ref())
.await
.map(|id| HashMap::from([(id, HashSet::from([broker::Field::Datapoint]))]))
.map(|id| {
HashMap::from([(
id,
(
HashSet::from([broker::Field::Datapoint]),
types::ChangeType::Static,
),
)])
})
else {
return Err(SubscribeErrorResponse {
request_id,
Expand Down

0 comments on commit eb93ef5

Please sign in to comment.