InputStreamProvider

@Factory

Override to provide a custom input stream.

Constructors

constructor()

@Singleton

@Named(value = "inputStream")

fun make(@Value(value = "${airbyte.connector.operation}") operation: String): InputStream