Method QueueSize

be/src/runtime/data-stream-test.cc:163–167

  }

  int QueueSize() {
    rapidjson::Document doc(rapidjson::kObjectType);
    rpc_mgr_->ToJson(&doc);
    return doc["services"][0]["queue_size"].GetInt();
  }

 private:
  RpcMgr* rpc_mgr_;