Struct RawTables 

pub struct RawTables { /* private fields */ }

Разобранные верхнеуровневые блоки ISS payload-а для декодирования нескольких таблиц.

Позволяет один раз разобрать payload и затем извлекать таблицы через RawTables::take_rows без повторного разбора всего JSON-документа.

Implementations

impl RawTables

pub fn len(&self) -> usize

Количество верхнеуровневых блоков в payload-е.

pub fn is_empty(&self) -> bool

Проверить, что payload не содержит верхнеуровневых блоков.

pub fn table_names(&self) -> impl Iterator<Item = &str>

Имена верхнеуровневых блоков payload-а.

Итератор отражает текущее состояние кэша: после take_rows(...) соответствующее имя больше не возвращается.

pub fn take_rows<T>( &mut self, table: impl AsRef<str>, ) -> Result<Vec<T>, MoexError>

where T: DeserializeOwned,

Декодировать строки выбранной таблицы и удалить её из кэша.

Метод потребляет только выбранный верхнеуровневый блок и не вызывает повторный разбор всего payload-а.

Examples found in repository

examples/actual_indexes_dump.rs (line 234)

fn parse_board_snapshots_page(
    payload: &str,
    endpoint: &str,
) -> Result<(Vec<SecuritySnapshot>, Option<SecId>), MoexError> {
    let mut tables = decode::raw_tables_json(payload, endpoint)?;
    let security_rows: Vec<RawSecuritySnapshotRow> = tables.take_rows("securities")?;
    let marketdata_rows: Vec<RawMarketdataSnapshotRow> = tables.take_rows("marketdata")?;

    let mut marketdata_by_secid = HashMap::with_capacity(marketdata_rows.len());
    for (row, marketdata) in marketdata_rows.into_iter().enumerate() {
        marketdata_by_secid.insert(marketdata.secid, (row, marketdata.last));
    }

    let mut first_secid_on_page = None;
    let mut snapshots = Vec::with_capacity(security_rows.len().max(marketdata_by_secid.len()));

    for (row, security) in security_rows.into_iter().enumerate() {
        let last = marketdata_by_secid
            .remove(security.secid.as_str())
            .and_then(|(_, last)| last);
        let snapshot = SecuritySnapshot::try_new(security.secid, security.lot_size, last).map_err(
            |source| MoexError::InvalidSecuritySnapshot {
                endpoint: endpoint.to_owned().into_boxed_str(),
                table: "securities",
                row,
                source,
            },
        )?;
        if first_secid_on_page.is_none() {
            first_secid_on_page = Some(snapshot.secid().clone());
        }
        snapshots.push(snapshot);
    }

    for (secid, (row, last)) in marketdata_by_secid {
        let snapshot = SecuritySnapshot::try_new(secid, None, last).map_err(|source| {
            MoexError::InvalidSecuritySnapshot {
                endpoint: endpoint.to_owned().into_boxed_str(),
                table: "marketdata",
                row,
                source,
            }
        })?;
        if first_secid_on_page.is_none() {
            first_secid_on_page = Some(snapshot.secid().clone());
        }
        snapshots.push(snapshot);
    }

    Ok((snapshots, first_secid_on_page))
}

Trait Implementations

impl Debug for RawTables

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

Formats the value using the given formatter.