invoke

operator fun invoke(block: FirehoseStream.Builder.() -> Unit): FirehoseStream