Skip to content

Commit

Permalink
Add Info about Stream being opened
Browse files Browse the repository at this point in the history
  • Loading branch information
wba2hi committed May 24, 2024
1 parent 3f58352 commit 6c14097
Showing 1 changed file with 2 additions and 0 deletions.
2 changes: 2 additions & 0 deletions databroker/src/grpc/kuksa_val_v1/val.rs
Original file line number Diff line number Diff line change
Expand Up @@ -25,6 +25,7 @@ use tokio_stream::Stream;
use tokio_stream::StreamExt;
use tonic::{Response, Status, Streaming};
use tracing::debug;
use tracing::info;

use crate::broker;
use crate::broker::ReadError;
Expand Down Expand Up @@ -304,6 +305,7 @@ impl proto::val_server::Val for broker::DataBroker {
let (sender, receiver) = mpsc::channel(10);
// Listening on stream
tokio::spawn(async move {
info!("Update Stream opened");
let permissions = permissions;
let broker = broker.authorized_access(&permissions);
loop {
Expand Down

0 comments on commit 6c14097

Please sign in to comment.