Method build_arc_database_row

collab/src/database/database_trait.rs:244–270

(
    &self,
    row_id: &RowId,
    data: Option<DatabaseRowDataVariant>,
    sender: Option<RowChangeSender>,
  )

  }

  async fn build_arc_database_row(
    &self,
    row_id: &RowId,
    data: Option<DatabaseRowDataVariant>,
    sender: Option<RowChangeSender>,
  ) -> Result<Arc<RwLock<DatabaseRow>>, CollabError> {
    if let Some(cache) = self.database_row_cache() {
      if let Some(cached_row) = cache.get(row_id) {
        return Ok(cached_row.clone());
      }
    }

    let client_id = self.reader_client_id().await;
    let collab_type = CollabType::DatabaseRow;
    let data = match data {
      None => self.reader_get_collab(row_id, collab_type).await?,
      Some(data) => data.into_encode_collab(client_id),
    };
    let collab = build_collab(client_id, row_id, collab_type, data).await?;
    let database_row = DatabaseRow::open(*row_id, collab, sender)?;
    let arc_row = Arc::new(RwLock::new(database_row));

    if let Some(cache) = self.database_row_cache() {
      cache.insert(*row_id, arc_row.clone());
    }
    Ok(arc_row)
  }

  async fn batch_build_arc_database_row(
    &self,