fn open_exclusive(config: S3BlobConfig, lock_info: LockInfo) -> Result<Self, Error> {
        block_on(async {
            let core = S3BlobCore {
                client: Some(config.client),
                bucket: config.bucket,
                prefix: config.prefix,
                max_keys: 1_000,
            };
            let mut blob = S3Blob { core };
            let _ = blob.lock(lock_info).await?;
            Ok(blob)
        })
    }
/// Returns a new [S3Blob] which stores objects under the given bucket and
/// prefix.
///
/// All calls to methods on [S3Blob] must be from a thread with a tokio
/// runtime guard.
//
// TODO: Figure out how to make this tokio runtime guard stuff more
// explicit.
Returns a new [S3Blob] which stores objects under the given bucket and
prefix.

All calls to methods on [S3Blob] must be from a thread with a tokio
runtime guard.

Figure out how to make this tokio runtime guard stuff more
explicit.
Returns a new [ S3Blob ] which stores objects under the given bucket and prefix . All calls to methods on [ S3Blob ] must be from a thread with a tokio runtime guard . Figure out how to make this tokio runtime guard stuff more explicit .
fn open_exclusive(config: S3BlobConfig, lock_info: LockInfo) -> Result<Self, Error> {
        block_on(async {
            let core = S3BlobCore {
                client: Some(config.client),
                bucket: config.bucket,
                prefix: config.prefix,
                max_keys: 1_000,
            };
            let mut blob = S3Blob { core };
            let _ = blob.lock(lock_info).await?;
            Ok(blob)
        })
    }
fn open_exclusive ( config : S3BlobConfig , lock_info : LockInfo ) -> Result < Self , Error > { block_on ( async { let core = S3BlobCore { client : Some ( config . client ) , bucket : config . bucket , prefix : config . prefix , max_keys : 1_000 , } ; let mut blob = S3Blob { core } ; let _ = blob . lock ( lock_info ) . await ? ; Ok ( blob ) } ) }
Returns a new [S3Blob] which stores objects under the given bucket and
prefix.
Returns a new [ S3Blob ] which stores objects under the given bucket and prefix .
config
S3BlobConfig
lock_info
LockInfo
config
S3BlobConfig
lock_info
LockInfo