refactor(player): remove old comments from get_status
This commit is contained in:
@@ -143,8 +143,6 @@ impl Player for PlayerService {
|
|||||||
let sleep_duration = Duration::from_millis(1000);
|
let sleep_duration = Duration::from_millis(1000);
|
||||||
|
|
||||||
tokio::spawn(async move {
|
tokio::spawn(async move {
|
||||||
println!("get_status stream opened");
|
|
||||||
|
|
||||||
while !tx.is_closed() {
|
while !tx.is_closed() {
|
||||||
if let Err(_) = tx
|
if let Err(_) = tx
|
||||||
.send(Ok(state.lock().await.player.get_snapshot().into()))
|
.send(Ok(state.lock().await.player.get_snapshot().into()))
|
||||||
@@ -155,8 +153,6 @@ impl Player for PlayerService {
|
|||||||
|
|
||||||
tokio::time::sleep(sleep_duration).await;
|
tokio::time::sleep(sleep_duration).await;
|
||||||
}
|
}
|
||||||
|
|
||||||
println!("get_status stream closed");
|
|
||||||
});
|
});
|
||||||
|
|
||||||
let output_stream = ReceiverStream::new(rx);
|
let output_stream = ReceiverStream::new(rx);
|
||||||
|
|||||||
Reference in New Issue
Block a user