method addResponse

Source

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);
  List rows = [];
  subscriptions.forEach((String path, _QuerySubscription sub) {
    List data = sub.getRowDataForNewResponse();
    if (data != null) {
      rows.add(data);
    }
  });
  response.updateStream(rows, columns: columns);
}