bulk-cdk-core-load/io.airbyte.cdk.load.dataflow.config/ConnectorInputStreams

ConnectorInputStreams

class ConnectorInputStreams(values: List<InputStream>) : List<InputStream>

Micronaut work around - wraps the input streams to avoid injecting a List directly, and being subject to Micronaut merging like beans into a single list leading to injecting unexpected extra input streams.

Constructors

constructor(values: List<InputStream>)

Properties

size

open override val size: Int

Functions

closeAll

fun closeAll()

contains

open operator override fun contains(element: InputStream): Boolean

containsAll

open override fun containsAll(elements: Collection<InputStream>): Boolean

get

open operator override fun get(index: Int): InputStream

indexOf

open override fun indexOf(element: InputStream): Int

isEmpty

open override fun isEmpty(): Boolean

iterator

open operator override fun iterator(): Iterator<InputStream>

lastIndexOf

open override fun lastIndexOf(element: InputStream): Int

listIterator

open override fun listIterator(): ListIterator<InputStream>

open override fun listIterator(index: Int): ListIterator<InputStream>

subList

open override fun subList(fromIndex: Int, toIndex: Int): List<InputStream>

toAirbyteValues

fun List<Meta.Change>.toAirbyteValues(): List<ObjectValue>