getFor

open override fun getFor(consumerId: String): Flow<T>