createListItemEmitter

open fun <T> createListItemEmitter(query: Query<T>, emitter: FlowableEmitter<T>)