mongo streams interface