writeTransaction method

ResponseStream<WriteTransactionReply> writeTransaction (
  1. StreamController<GeneratedMessage> writer
)

Create a write transaction stream

Implementation

ResponseStream<WriteTransactionReply> writeTransaction(StreamController<GeneratedMessage> writer) {
  // Create transation input stream
  final controller = StreamController<WriteTransactionRequest>();

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

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

  return listener;
}