getFeedEntries static method

Future<FeedFrameResponse> getFeedEntries(
  1. P2PStream stream, {
  2. required PeerId ownerPeerId,
  3. required String path,
  4. int? fromSequence,
  5. int? toSequence,
  6. int? limit,
  7. String? entryType,
})

Get feed entries (range query)

Implementation

static Future<FeedFrameResponse> getFeedEntries(
  P2PStream stream, {
  required PeerId ownerPeerId,
  required String path,
  int? fromSequence,
  int? toSequence,
  int? limit,
  String? entryType,
}) async {
  try {
    final requestBytes = FeedFrame.encodeRequest(
      operation: 'GET',
      ownerPeerId: ownerPeerId,
      path: path,
      fromSequence: fromSequence,
      toSequence: toSequence,
      limit: limit,
      entryType: entryType,
    );

    await _writeFrameStatic(stream, requestBytes);
    final responseBytes = await _readFrameStatic(stream);
    return FeedFrame.decodeResponse(responseBytes);
  } catch (e, stackTrace) {
    _logger.severe('Error getting feed entries: $e', e, stackTrace);
    rethrow;
  }
}