export interface StreamProducer {
    read(): Promise<{
        done: boolean;
        value: any;
    }>;
}