if mime_type.endswith("mpeg"):
mime_type = sonic_song.suffix
+ self.logger.debug(
+ "Fetching stream details for id %s '%s' with format '%s'",
+ sonic_song.id,
+ sonic_song.title,
+ mime_type,
+ )
+
return StreamDetails(
item_id=sonic_song.id,
provider=self.instance_id,
"""Provide a generator for the stream data."""
audio_buffer = asyncio.Queue(1)
+ self.logger.debug("Streaming %s", streamdetails.item_id)
+
def _streamer() -> None:
with self._conn.stream(
streamdetails.item_id, timeOffset=seek_position, estimateContentLength=True
finally:
if not streamer_task.done():
streamer_task.cancel()
+
+ self.logger.debug("Done streaming %s", streamdetails.item_id)