Class AzureBlobReactiveBucketOperations

java.lang.Object

io.micronaut.objectstorage.azure.AzureBlobReactiveBucketOperations

All Implemented Interfaces:

ReactiveBucketOperations<com.azure.storage.blob.models.BlobContainerProperties>

@EachBean(com.azure.storage.blob.BlobServiceAsyncClient.class)
@Requires(beans=com.azure.storage.blob.BlobServiceAsyncClient.class)
public class AzureBlobReactiveBucketOperations
extends Object
implements ReactiveBucketOperations<com.azure.storage.blob.models.BlobContainerProperties>

Reactive Azure bucket operations.

Since:

3.0.0

Author:

Álvaro Sánchez-Mariscal

Constructor Summary

Constructors

Constructor	Description
AzureBlobReactiveBucketOperations(com.azure.storage.blob.BlobServiceAsyncClient blobServiceAsyncClient)

Method Summary

Modifier and Type	Method	Description
@NonNull org.reactivestreams.Publisher<Void>	create(@NonNull String name)	Create a new bucket/container with the given name.
@NonNull org.reactivestreams.Publisher<Void>	delete(@NonNull String name)	Delete a bucket/container with the given name.
@NonNull org.reactivestreams.Publisher<Boolean>	exists(@NonNull String name)	Checks whether a bucket/container exists.
@NonNull org.reactivestreams.Publisher<Optional<BucketEntry<com.azure.storage.blob.models.BlobContainerProperties>>>	retrieve(@NonNull String name)	Retrieve an existing bucket/container.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

AzureBlobReactiveBucketOperations

public AzureBlobReactiveBucketOperations(com.azure.storage.blob.BlobServiceAsyncClient blobServiceAsyncClient)

Method Details

create

public @NonNull org.reactivestreams.Publisher<Void> create(@NonNull String name)

Description copied from interface: ReactiveBucketOperations

Create a new bucket/container with the given name.

Specified by:

create in interface ReactiveBucketOperations<com.azure.storage.blob.models.BlobContainerProperties>

Parameters:

name - The bucket/container name.

Returns:

a completion-only publisher.

retrieve

public @NonNull org.reactivestreams.Publisher<Optional<BucketEntry<com.azure.storage.blob.models.BlobContainerProperties>>> retrieve(@NonNull String name)

Description copied from interface: ReactiveBucketOperations

Retrieve an existing bucket/container.

Specified by:

retrieve in interface ReactiveBucketOperations<com.azure.storage.blob.models.BlobContainerProperties>

Parameters:

name - The bucket/container name.

Returns:

a publisher that emits the provider-native bucket/container data if it exists.

delete

public @NonNull org.reactivestreams.Publisher<Void> delete(@NonNull String name)

Description copied from interface: ReactiveBucketOperations

Delete a bucket/container with the given name.

Specified by:

delete in interface ReactiveBucketOperations<com.azure.storage.blob.models.BlobContainerProperties>

Parameters:

name - The bucket/container name.

Returns:

a completion-only publisher.

exists

public @NonNull org.reactivestreams.Publisher<Boolean> exists(@NonNull String name)

Description copied from interface: ReactiveBucketOperations

Checks whether a bucket/container exists.

Specified by:

exists in interface ReactiveBucketOperations<com.azure.storage.blob.models.BlobContainerProperties>

Parameters:

name - The bucket/container name.

Returns:

a publisher that emits true if the bucket/container exists.