getDataStream method

@override Future<List<DataStreamBatch>> getDataStream(DataStreamId dataStream, int fromSequenceId, [ int? toSequenceIdInclusive ])

Retrieve all data points in dataStream that fall within the inclusive range defined by fromSequenceId and toSequenceIdInclusive. If toSequenceIdInclusive is null, all data points starting fromSequenceId are returned.

In case no data for dataStream is stored in this repository, or is available for the specified range, an empty list is returned.

Throws IllegalArgumentException if:

• dataStream has never been opened
• fromSequenceId is negative or toSequenceIdInclusive is smaller than fromSequenceId

Implementation

@override
Future<List<DataStreamBatch>> getDataStream(
  DataStreamId dataStream,
  int fromSequenceId, [
  int? toSequenceIdInclusive,
]) async {
  Map<String, dynamic> responseJson = await _rpc(GetDataStream(
    dataStream,
    fromSequenceId,
    toSequenceIdInclusive,
  ));

  // we expect a list of 'items'
  List<dynamic> items = responseJson['items'] as List<dynamic>;

  return (items.isEmpty)
      ? []
      : items
          .map((item) =>
              DataStreamBatch.fromJson(item as Map<String, dynamic>))
          .toList();
}