Airbyte Kotlin Bulk CDK

0.1.92

bulk-cdk-core-load/io.airbyte.cdk.load.file/ClientSocket

ClientSocket

class ClientSocket(val socketPath: String, bufferSizeBytes: Int, connectWaitDelayMs: Long = 1000, connectTimeoutMs: Long = 15 * 60 * 1000L)

Constructors

constructor(socketPath: String, bufferSizeBytes: Int, connectWaitDelayMs: Long = 1000, connectTimeoutMs: Long = 15 * 60 * 1000L)

Properties

val socketPath: String

Functions

suspend fun connect(block: suspend (InputStream) -> Unit)

openInputStream

fun openInputStream(): InputStream