bulk-cdk-core-load/io.airbyte.cdk.load.dataflow.config/InputBeanFactory/messageFlows

messageFlows

@Named(value = "messageFlows")
@Singleton
fun messageFlows(@Named(value = "inputStreams") inputStreams: ConnectorInputStreams, @Value(value = "${airbyte.destination.core.data-channel.format}") dataChannelFormat: DataChannelFormat, deserializer: ProtocolMessageDeserializer, destinationMessageFactory: DestinationMessageFactory): List<Flow<DestinationMessage>>