Struct yrs::types::array::ArrayRef

pub struct ArrayRef(/* private fields */);

A collection used to store data in an indexed sequence structure. This type is internally implemented as a double linked list, which may squash values inserted directly one after another into single list node upon transaction commit.

Reading a root-level type as an ArrayRef means treating its sequence components as a list, where every countable element becomes an individual entity:

• JSON-like primitives (booleans, numbers, strings, JSON maps, arrays etc.) are counted individually.
• Text chunks inserted by [Text] data structure: each character becomes an element of an array.
• Embedded and binary values: they count as a single element even though they correspond of multiple bytes.

Like all Yrs shared data types, ArrayRef is resistant to the problem of interleaving (situation when elements inserted one after another may interleave with other peers concurrent inserts after merging all updates together). In case of Yrs conflict resolution is solved by using unique document id to determine correct and consistent ordering.

Example

use yrs::{Array, Doc, Map, MapPrelim, Transact, Any, any};
use yrs::types::ToJson;

let doc = Doc::new();
let array = doc.get_or_insert_array("array");
let mut txn = doc.transact_mut();

// insert single scalar value
array.insert(&mut txn, 0, "value");
array.remove_range(&mut txn, 0, 1);

assert_eq!(array.len(&txn), 0);

// insert multiple values at once
array.insert_range(&mut txn, 0, ["a", "b", "c"]);
assert_eq!(array.len(&txn), 3);

// get value
let value = array.get(&txn, 1);
assert_eq!(value, Some("b".into()));

// insert nested shared types
let map = array.insert(&mut txn, 1, MapPrelim::from([("key1", "value1")]));
map.insert(&mut txn, "key2", "value2");

assert_eq!(array.to_json(&txn), any!([
  "a",
  { "key1": "value1", "key2": "value2" },
  "b",
  "c"
]));

Trait Implementations

impl Array for ArrayRef

fn len<T: ReadTxn>(&self, txn: &T) -> u32

Returns a number of elements stored in current array.

fn insert<V>( &self, txn: &mut TransactionMut<'_>, index: u32, value: V ) -> V::Returnwhere V: Prelim,

Inserts a value at the given index. Inserting at index 0 is equivalent to prepending current array with given value, while inserting at array length is equivalent to appending that value at the end of it.

fn insert_range<T, V>( &self, txn: &mut TransactionMut<'_>, index: u32, values: T )where T: IntoIterator<Item = V>, V: Into<Any>,

Inserts multiple values at the given index. Inserting at index 0 is equivalent to prepending current array with given values, while inserting at array length is equivalent to appending that value at the end of it.

fn push_back<V>(&self, txn: &mut TransactionMut<'_>, value: V) -> V::Returnwhere V: Prelim,

Inserts given value at the end of the current array.

fn push_front<V>(&self, txn: &mut TransactionMut<'_>, content: V) -> V::Returnwhere V: Prelim,

Inserts given value at the beginning of the current array.

fn remove(&self, txn: &mut TransactionMut<'_>, index: u32)

Removes a single element at provided index.

fn remove_range(&self, txn: &mut TransactionMut<'_>, index: u32, len: u32)

Removes a range of elements from current array, starting at given index up until a particular number described by len has been deleted. This method panics in case when not all expected elements were removed (due to insufficient number of elements in an array) or index is outside of the bounds of an array.

fn get<T: ReadTxn>(&self, txn: &T, index: u32) -> Option<Value>

Retrieves a value stored at a given index. Returns None when provided index was out of the range of a current array.

fn move_to(&self, txn: &mut TransactionMut<'_>, source: u32, target: u32)

Moves element found at source index into target index position. Both indexes refer to a current state of the document.

fn move_range_to( &self, txn: &mut TransactionMut<'_>, start: u32, assoc_start: Assoc, end: u32, assoc_end: Assoc, target: u32 )

Moves all elements found within start..end indexes range (both side inclusive) into new position pointed by target index. All elements inserted concurrently by other peers inside of moved range will be moved as well after synchronization (although it make take more than one sync roundtrip to achieve convergence).

fn iter<'a, T: ReadTxn + 'a>(&self, txn: &'a T) -> ArrayIter<&'a T, T>

Returns an iterator, that can be used to lazely traverse over all values stored in a current array.

impl AsMut<Branch> for ArrayRef

fn as_mut(&mut self) -> &mut Branch

Converts this type into a mutable reference of the (usually inferred) input type.

impl AsRef<Branch> for ArrayRef

fn as_ref(&self) -> &Branch

Converts this type into a shared reference of the (usually inferred) input type.

impl Clone for ArrayRef

fn clone(&self) -> ArrayRef

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ArrayRef

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl From<BranchPtr> for ArrayRef

fn from(inner: BranchPtr) -> Self

Converts to this type from the input type.

impl IndexedSequence for ArrayRef

fn sticky_index( &self, txn: &mut TransactionMut<'_>, index: u32, assoc: Assoc ) -> Option<StickyIndex>

Returns a StickyIndex equivalent to a human-readable index. Returns None if index is beyond the length of current sequence.

impl Into<ArrayRef> for XmlElementRef

fn into(self) -> ArrayRef

Converts this type into the (usually inferred) input type.

impl Observable for ArrayRef

type Event = ArrayEvent

fn try_observer( &self ) -> Option<&Observer<Arc<dyn Fn(&TransactionMut<'_>, &Self::Event)>>>

fn try_observer_mut( &mut self ) -> Option<&mut Observer<Arc<dyn Fn(&TransactionMut<'_>, &Self::Event)>>>

fn observe<F>( &mut self, f: F ) -> Subscription<Arc<dyn Fn(&TransactionMut<'_>, &Self::Event)>>where F: Fn(&TransactionMut<'_>, &Self::Event) + 'static,

Subscribes a given callback to be triggered whenever current y-type is changed. A callback is triggered whenever a transaction gets committed. This function does not trigger if changes have been observed by nested shared collections.

fn unobserve(&self, subscription_id: SubscriptionId)

Unsubscribes a previously subscribed event callback identified by given subscription_id.

impl PartialEq for ArrayRef

fn eq(&self, other: &ArrayRef) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl ToJson for ArrayRef

fn to_json<T: ReadTxn>(&self, txn: &T) -> Any

Converts all contents of a current type into a JSON-like representation.

impl TryFrom<BlockPtr> for ArrayRef

type Error = BlockPtr

The type returned in the event of a conversion error.

fn try_from(value: BlockPtr) -> Result<Self, Self::Error>

Performs the conversion.

impl TryFrom<Value> for ArrayRef

type Error = Value

The type returned in the event of a conversion error.

fn try_from(value: Value) -> Result<Self, Self::Error>

Performs the conversion.

impl Eq for ArrayRef

impl SharedRef for ArrayRef

impl StructuralEq for ArrayRef

impl StructuralPartialEq for ArrayRef