pub async fn put<S>(&self, location: &str, bytes: S, length: usize) -> Result<()>
    where
        S: Stream<Item = io::Result<Bytes>> + Send + Sync + 'static,
    {
        use ObjectStoreIntegration::*;
        match &self.0 {
            AmazonS3(s3) => s3.put(location, bytes, length).await?,
            GoogleCloudStorage(gcs) => gcs.put(location, bytes, length).await?,
            InMemory(in_mem) => in_mem.put(location, bytes, length).await?,
            File(file) => file.put(location, bytes, length).await?,
        }

        Ok(())
    }
/// Save the provided bytes to the specified location.
Save the provided bytes to the specified location.
Save the provided bytes to the specified location .
pub async fn put<S>(&self, location: &str, bytes: S, length: usize) -> Result<()>
    where
        S: Stream<Item = io::Result<Bytes>> + Send + Sync + 'static,
    {
        use ObjectStoreIntegration::*;
        match &self.0 {
            AmazonS3(s3) => s3.put(location, bytes, length).await?,
            GoogleCloudStorage(gcs) => gcs.put(location, bytes, length).await?,
            InMemory(in_mem) => in_mem.put(location, bytes, length).await?,
            File(file) => file.put(location, bytes, length).await?,
        }
        Ok(())
    }
pub async fn put < S > ( & self , location : & str , bytes : S , length : usize ) -> Result < ( ) > where S : Stream < Item = io :: Result < Bytes > > + Send + Sync + ' static , { use ObjectStoreIntegration :: * ; match & self . 0 { AmazonS3 ( s3 ) => s3 . put ( location , bytes , length ) . await ? , GoogleCloudStorage ( gcs ) => gcs . put ( location , bytes , length ) . await ? , InMemory ( in_mem ) => in_mem . put ( location , bytes , length ) . await ? , File ( file ) => file . put ( location , bytes , length ) . await ? , } Ok ( ( ) ) }
Save the provided bytes to the specified location.
Save the provided bytes to the specified location .
&self
location
&str
bytes
S
length
usize