suspend fun S3Client.store(bucketName: String, resourceKey: String, data: Flux<DataBuffer>) {
 this.createBucketIfNotExists(bucketName)
 val mediaType = MediaTypeFactory.getMediaType(resourceKey)
 .orElseGet { MediaType.APPLICATION_OCTET_STREAM }
 val byteArrayFlow = data
 .map { dataBuffer ->
 val bytes = ByteArray(dataBuffer.readableByteCount())
 dataBuffer.read(bytes)
 DataBufferUtils.release(dataBuffer)
 bytes
 }
 .asFlow()
 val request = PutObjectRequest {
 bucket = bucketName
 body = byteArrayFlow.toByteStream(applicationScope) // here I use toByteStream to transfer the data type.
 key = resourceKey
 contentType = mediaType.toString()
 }
 val result = try {
 this.putObject(request)
 } catch (e: Exception) {
 throw S3ClientException(e.message ?: "Failed to store object $resourceKey")
 }
 println("store object to $bucketName: ${result.eTag}")
}