addResponse method

  1. @override
void addResponse(
  1. InvokeResponse response
)
override

Implementation

@override
void addResponse(InvokeResponse response) {
  if (_pending) {
    // send all pending update to existing responses
    // so the new response can continue on a clear state
    _doUpdate();
  }
  super.addResponse(response);
  var rows = <dynamic>[];
  subscriptions.forEach((String path, _QuerySubscription sub) {
    var data = sub.getRowDataForNewResponse();
    if (data != null) {
      rows.add(data);
    }
  });
  response.updateStream(rows, columns: columns);
}