export interface IFirehoseAdapter {
    stream(record: string): Promise<void>;
}