s3s-aws 0.13.0

S3 service adapter integrated with aws-sdk-s3
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

use sync_wrapper::{SyncFuture, SyncWrapper};
use transform_stream::AsyncStream;

type AwsSelectObjectContentEventStream = aws_sdk_s3::primitives::event_stream::EventReceiver<
    aws_sdk_s3::types::SelectObjectContentEventStream,
    aws_sdk_s3::types::error::SelectObjectContentEventStreamError,
>;

pub fn from_aws(src: AwsSelectObjectContentEventStream) -> s3s::dto::SelectObjectContentEventStream {
    let mut src = SyncWrapper::new(src);
    s3s::dto::SelectObjectContentEventStream::new(AsyncStream::new(|mut y| async move {
        loop {
            let recv = SyncFuture::new(src.get_mut().recv());
            let ans = recv.await;
            match ans {
                Ok(Some(ev)) => y.yield_(crate::conv::try_from_aws(ev)).await,
                Ok(None) => break,
                Err(err) => y.yield_err(wrap_sdk_error!(err)).await,
            }
        }
    }))
}