Struct AsyncPutObject 

pub struct AsyncPutObject<'a> { /* private fields */ }

Implements the AsyncWrite trait and writes data to S3 using the put_object API.

Example

use aws_config;
use cobalt_aws::s3::{AsyncPutObject, Client};
use cobalt_aws::config::load_from_env;
use futures::AsyncWriteExt;

let shared_config = load_from_env().await.unwrap();
let client = Client::new(&shared_config);

let mut writer = AsyncPutObject::new(&client, "my-bucket", "my-key");
writer.write_all(b"File contents").await.unwrap();

// The contents are pushed to S3 when the `.close()` method is called.
writer.close().await.unwrap();

Implementations

impl<'a> AsyncPutObject<'a>

pub fn new(client: &'a Client, bucket: &str, key: &str) -> Self

Create a new AsyncPutObject which will write data to the given bucket and key.

Trait Implementations

impl<'a> AsyncWrite for AsyncPutObject<'a>

fn poll_write( self: Pin<&mut Self>, _cx: &mut Context<'_>, buf: &[u8], ) -> Poll<Result<usize, Error>>

Attempt to write bytes from buf into the object.

fn poll_flush( self: Pin<&mut Self>, _cx: &mut Context<'_>, ) -> Poll<Result<(), Error>>

Attempt to flush the object, ensuring that any buffered data reach their destination.

fn poll_close<'b>( self: Pin<&'b mut AsyncPutObject<'a>>, cx: &'b mut Context<'_>, ) -> Poll<Result<(), Error>>

Attempt to close the object.

fn poll_write_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &[IoSlice<'_>], ) -> Poll<Result<usize, Error>>

Attempt to write bytes from bufs into the object using vectored IO operations.