Package com.terracottatech.store.async

Interface AsyncDatasetReader<K extends Comparable<K>>

All Known Subinterfaces:

AsyncDatasetWriterReader<K>

public interface AsyncDatasetReader<K extends Comparable<K>>

An asynchronous equivalent to DatasetReader.

Method Summary

Modifier and Type	Method	Description
Operation<Optional<Record<K>>>	get(K key)	An asynchronous equivalent to DatasetReader.get(Comparable).
AsyncReadRecordAccessor<K>	on(K key)	Equivalent to DatasetReader.on(Comparable), but returns an AsyncReadRecordAccessor rather than a ReadRecordAccessor.
AsyncRecordStream<K>	records()	Returns an AsyncStream of the records in this dataset.

Method Details

get

Operation<Optional<Record<K>>> get(K key)

An asynchronous equivalent to DatasetReader.get(Comparable).

Parameters:

key - key for the record

Returns:

an operation representing the get execution

on

AsyncReadRecordAccessor<K> on(K key)

Equivalent to DatasetReader.on(Comparable), but returns an AsyncReadRecordAccessor rather than a ReadRecordAccessor.

Parameters:

key - key of the record

Returns:

an AsyncReadRecordAccessor

records

AsyncRecordStream<K> records()

Returns an AsyncStream of the records in this dataset.

Returns:

an asynchronous stream of records