Method create_arc_database_row

collab/src/database/database_trait.rs:222–242

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

  }

  async fn create_arc_database_row(
    &self,
    row_id: &RowId,
    data: DatabaseRowDataVariant,
    sender: Option<RowChangeSender>,
  ) -> Result<Arc<RwLock<DatabaseRow>>, CollabError> {
    let client_id = self.reader_client_id().await;
    let collab_type = CollabType::DatabaseRow;
    let data = data.into_encode_collab(client_id);
    if let Some(persistence) = self.reader_persistence() {
      persistence.upsert_collab(row_id, data.clone())?;
    }

    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 build_arc_database_row(
    &self,