from typing import TypeVar, Generic from external_api.base.analytics_models import TrackStreamsQuery, TrackStreamsResult T = TypeVar("T") class TrackStreamsProvider(Generic[T]): client: T def __init__(self, client: T): self.client = client async def fetch(self, query: TrackStreamsQuery) -> TrackStreamsResult: raise NotImplementedError