registerProcessor

fun registerProcessor(factory: () -> FlowProcessor<K, V>)