readTransaction method

ResponseStream<ReadTransactionReply> readTransaction (
  1. StreamController<GeneratedMessage> writer
)

Create a read transaction steam

Implementation

ResponseStream<ReadTransactionReply> readTransaction(StreamController<GeneratedMessage> writer) {
  // Create transation input stream
  final controller = StreamController<ReadTransactionRequest>();

  // Transform user inputs to TransactionRequests
  final transform = returnReadTransform();
  writer.stream.transform(transform).pipe(controller);

  // Register stream and get listener
  final listener = _stub.readTransaction(controller.stream);

  return listener;
}