Source code for viam.media.media
import sys
if sys.version_info >= (3, 9):
from collections.abc import AsyncIterator
else:
from typing import AsyncIterator
from typing import Protocol, TypeVar
MediaType = TypeVar("MediaType", covariant=True)
[docs]class MediaStreamWithIterator(MediaStream[MediaType]):
_stream: AsyncIterator[MediaType]
def __init__(self, stream: AsyncIterator[MediaType]):
self._stream = stream