Class DefaultReactiveObjectMetadataOperations<T>

java.lang.Object

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

Type Parameters:

T - The provider-native metadata representation type.

All Implemented Interfaces:

ReactiveObjectMetadataOperations<T>

Direct Known Subclasses:

LocalStorageReactiveObjectMetadataOperations

@Internal
public class DefaultReactiveObjectMetadataOperations<T>
extends Object
implements ReactiveObjectMetadataOperations<T>

Executor-backed reactive adapter for the blocking object metadata contract.

Since:

3.0.0

Author:

Álvaro Sánchez-Mariscal

Constructor Summary

Constructors

Constructor	Description
DefaultReactiveObjectMetadataOperations(ObjectMetadataOperations<T> delegate, ExecutorService blockingExecutor)

Method Summary

Modifier and Type	Method	Description
@NonNull org.reactivestreams.Publisher<Void>	delete(@NonNull String key)	Deletes the metadata snapshot for an object.
@NonNull org.reactivestreams.Publisher<Boolean>	exists(@NonNull String key)	Checks whether a metadata snapshot exists for an object.
@NonNull org.reactivestreams.Publisher<Optional<ObjectMetadataEntry<T>>>	retrieve(@NonNull String key)	Retrieves the stored metadata snapshot for an object.
@NonNull org.reactivestreams.Publisher<Void>	save(@NonNull ObjectMetadataWrite write)	Saves a metadata snapshot for an object.

Methods inherited from class Object

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

Constructor Details

DefaultReactiveObjectMetadataOperations

public DefaultReactiveObjectMetadataOperations(ObjectMetadataOperations<T> delegate,
 ExecutorService blockingExecutor)

Method Details

retrieve

public @NonNull org.reactivestreams.Publisher<Optional<ObjectMetadataEntry<T>>> retrieve(@NonNull String key)

Description copied from interface: ReactiveObjectMetadataOperations

Retrieves the stored metadata snapshot for an object.

Specified by:

retrieve in interface ReactiveObjectMetadataOperations<T>

Parameters:

key - The object key.

Returns:

A publisher that emits the metadata entry if one exists.

save

public @NonNull org.reactivestreams.Publisher<Void> save(@NonNull ObjectMetadataWrite write)

Description copied from interface: ReactiveObjectMetadataOperations

Saves a metadata snapshot for an object.

Specified by:

save in interface ReactiveObjectMetadataOperations<T>

Parameters:

write - The metadata snapshot to persist.

Returns:

A completion-only publisher.

delete

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

Description copied from interface: ReactiveObjectMetadataOperations

Deletes the metadata snapshot for an object.

Specified by:

delete in interface ReactiveObjectMetadataOperations<T>

Parameters:

key - The object key.

Returns:

A completion-only publisher.

exists

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

Description copied from interface: ReactiveObjectMetadataOperations

Checks whether a metadata snapshot exists for an object.

Specified by:

exists in interface ReactiveObjectMetadataOperations<T>

Parameters:

key - The object key.

Returns:

A publisher that emits true if metadata exists for the object.