Package com.terracottatech.store.async

Interface AsyncDatasetWriterReader<K extends Comparable<K>>

All Superinterfaces:

AsyncDatasetReader<K>

public interface AsyncDatasetWriterReader<K extends Comparable<K>>
extends AsyncDatasetReader<K>

An asynchronous equivalent to DatasetWriterReader.

Method Summary

Modifier and Type	Method	Description
default Operation<Boolean>	add(K key, Cell<?>... cells)	An asynchronous equivalent to DatasetWriterReader.add(Comparable, Cell...).
Operation<Boolean>	add(K key, Iterable<Cell<?>> cells)	An asynchronous equivalent to DatasetWriterReader.add(Comparable, Iterable).
Operation<Boolean>	delete(K key)	An asynchronous equivalent to DatasetWriterReader.delete(Comparable).
AsyncReadWriteRecordAccessor<K>	on(K key)	Equivalent to DatasetWriterReader.on(Comparable), but returns an AsyncReadWriteRecordAccessor rather than a ReadWriteRecordAccessor.
AsyncMutableRecordStream<K>	records()	Returns an AsyncStream of the records in this dataset.
Operation<Boolean>	update(K key, UpdateOperation<? super K> transform)	An asynchronous equivalent to DatasetWriterReader.update(Comparable, UpdateOperation).

Methods inherited from interface com.terracottatech.store.async.AsyncDatasetReader

get

Method Details

add

default Operation<Boolean> add(K key,
 Cell<?>... cells)

An asynchronous equivalent to DatasetWriterReader.add(Comparable, Cell...).

Parameters:

key - key for the record

cells - cells which form the record

Returns:

an operation representing the add execution

add

Operation<Boolean> add(K key,
 Iterable<Cell<?>> cells)

An asynchronous equivalent to DatasetWriterReader.add(Comparable, Iterable).

Parameters:

key - key for the record

cells - a non-null Iterable supplying cells which form the record

Returns:

an operation representing the add execution

Throws:

NullPointerException - if cells is null

update

Operation<Boolean> update(K key,
 UpdateOperation<? super K> transform)

An asynchronous equivalent to DatasetWriterReader.update(Comparable, UpdateOperation).

Parameters:

key - key of the record to mutate

transform - the mutating transformation to apply to the record

Returns:

an operation representing the update execution

delete

Operation<Boolean> delete(K key)

An asynchronous equivalent to DatasetWriterReader.delete(Comparable).

Parameters:

key - key of the record to remove

Returns:

an operation representing the delete execution

on

AsyncReadWriteRecordAccessor<K> on(K key)

Equivalent to DatasetWriterReader.on(Comparable), but returns an AsyncReadWriteRecordAccessor rather than a ReadWriteRecordAccessor.

Specified by:

on in interface AsyncDatasetReader<K extends Comparable<K>>

Parameters:

key - key of the record

Returns:

an AsyncReadWriteRecordAccessor

records

AsyncMutableRecordStream<K> records()

Description copied from interface: AsyncDatasetReader

Returns an AsyncStream of the records in this dataset.

Specified by:

records in interface AsyncDatasetReader<K extends Comparable<K>>

Returns:

an asynchronous stream of records