socketStreams

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