newOperations method

Stream<SignedOperation> newOperations({ List<NewOperationsFilter>? filters, })

stream new operations

Implementation

Stream<SignedOperation> newOperations({List<NewOperationsFilter>? filters}) async* {
  final requestStream = StreamController<NewOperationsRequest>();
  if (filters != null) {
    final req = NewOperationsRequest(filters: filters);
    requestStream.add(req);
  }
  final response = publicServiceClient.newOperations(
    requestStream.stream.map((request) => request),
    options: CallOptions(),
  );
  try {
    await for (final resp in response) {
      yield resp.signedOperation;
    }
  } catch (e) {
    throw 'error streaming operations: $e';
  } finally {
    response.cancel();
  }
}