Subscriptions

from typing import AsyncGenerator
from fastql import Field, Subscription, subscribe


@Subscription
class Subscriptions:
    @Field
    async def counter(self, to: int = 3) -> AsyncGenerator[int, None]:
        for value in range(to):
            yield value


async for result in await subscribe(schema, "subscription { counter(to: 2) }"):
    print(result.data)          # {'counter': 0}, then {'counter': 1}