subscribeCheckpoints method

Stream<SubscribeCheckpointsResponse> subscribeCheckpoints({
  1. List<String>? readMask,
})

Subscribe to the stream of executed checkpoints (server-streaming). Replaces the deprecated JSON-RPC WebSocket subscriptions.

Implementation

Stream<SubscribeCheckpointsResponse> subscribeCheckpoints({
  List<String>? readMask,
}) {
  final req = SubscribeCheckpointsRequest(
    readMask: _mask(readMask ?? const ['sequence_number', 'digest']),
  );
  return _t
      .serverStream(_subscription, 'SubscribeCheckpoints',
          Uint8List.fromList(req.writeToBuffer()))
      .map(SubscribeCheckpointsResponse.fromBuffer);
}