Class DefaultReactiveBucketOperations<T>

java.lang.Object

io.micronaut.objectstorage.internal.DefaultReactiveBucketOperations<T>

Type Parameters:

T - The provider-native bucket/container representation type.

All Implemented Interfaces:

ReactiveBucketOperations<T>

Direct Known Subclasses:

LocalStorageReactiveBucketOperations

@Internal
public class DefaultReactiveBucketOperations<T>
extends Object
implements ReactiveBucketOperations<T>

Executor-backed reactive adapter for the blocking bucket/container contract.

Since:

3.0.0

Author:

Álvaro Sánchez-Mariscal

Constructor Summary

Constructors

Constructor	Description
DefaultReactiveBucketOperations(BucketOperations<T> delegate, ExecutorService blockingExecutor)

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<T>>>	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

DefaultReactiveBucketOperations

public DefaultReactiveBucketOperations(BucketOperations<T> delegate,
 ExecutorService blockingExecutor)

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<T>

Parameters:

name - The bucket/container name.

Returns:

a completion-only publisher.

retrieve

public @NonNull org.reactivestreams.Publisher<Optional<BucketEntry<T>>> retrieve(@NonNull String name)

Description copied from interface: ReactiveBucketOperations

Retrieve an existing bucket/container.

Specified by:

retrieve in interface ReactiveBucketOperations<T>

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<T>

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<T>

Parameters:

name - The bucket/container name.

Returns:

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