Teimatini Marin
07/29/2022, 4:24 PMoverride suspend fun read(channel: Channel<String>) {
val req = GetObjectRequest {
bucket = "localbucket"
key = "part2.csv"
}
s3.getObject(req) { resp ->
val stream = resp.body as ByteStream.OneShotStream
val flow = produceFlow(stream.readFrom())
consumeFlow(flow, channel)
}
}
where getObject is defined as
suspend fun <T> getObject(input: GetObjectRequest, block: suspend (GetObjectResponse) -> T): T