writeTransaction method
- 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;
}