folly::Future RawAsyncTable::CheckAndPut()

in src/hbase/client/raw-async-table.cc [115:139]

• 22 lines of code
• 1 McCabe index (conditional complexity)

folly::Future<bool> RawAsyncTable::CheckAndPut(const std::string& row, const std::string& family,
                                               const std::string& qualifier,
                                               const std::string& value, const hbase::Put& put,
                                               const pb::CompareType& compare_op) {
  auto caller =
      CreateCallerBuilder<bool>(row, connection_conf_->write_rpc_timeout())
          ->action([=, &put](std::shared_ptr<hbase::HBaseRpcController> controller,
                             std::shared_ptr<hbase::RegionLocation> loc,
                             std::shared_ptr<hbase::RpcClient> rpc_client) -> folly::Future<bool> {
            return Call<hbase::Put, hbase::Request, hbase::Response, bool>(
                rpc_client, controller, loc, put,
                // request conversion
                [=, &put](const hbase::Put& pt,
                          const std::string& region_name) -> std::unique_ptr<Request> {
                  auto checkReq = RequestConverter::CheckAndPutToMutateRequest(
                      row, family, qualifier, value, compare_op, pt, region_name);
                  return checkReq;
                },
                // response conversion
                &ResponseConverter::BoolFromMutateResponse);
          })
          ->Build();

  return caller->Call().then([caller](const auto r) { return r; });
}