apibara.protocol

from grpc import ssl_channel_credentials
from grpc.aio import secure_channel

channel = secure_channel("mainnet.starknet.a5a.ch", ssl_channel_credentials())
# or
channel = insecure_channel("localhost:7171")

(client, stream) = StreamService(channel).stream_data()

class StreamService:
    """
    An Apibara Stream service.

    Arguments
    ---------
    channel: grpc.aio.Channel
        the grpc channel
    """

    def __init__(self, channel: Channel) -> None:
        ...

    def stream_data(self) -> Tuple[StreamClient, StreamIter]:
        ...

(client, stream) = StreamService(channel).stream_data()
await client.configure(filter=my_filter)

class StreamClient:
    async def configure(
        self,
        *,
        filter: Optional[bytes] = None,
        batch_size: Optional[int] = None,
        finality: Optional[DataFinality.ValueType] = None,
        cursor: Optional[Cursor] = None
    ):
        ...

(client, stream) = StreamService(channel).stream_data()

async for message in stream:
    if message.data is not None:
        # data message
        pass
    elif message.invalidate is not None:
        # invalidate message
        pass

class StreamIter:
    async def __anext__(self):
        ...