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

socketStreams

@Requires(property = "airbyte.destination.core.data-channel.medium", value = "SOCKET")
@Named(value = "inputStreams")
@Singleton
fun socketStreams(sockets: List<ClientSocket>): ConnectorInputStreams