pipecircuit 0.0.22

Correct. Robust. Fast. Portable. Pick four.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63

use super::{WarpTable, WarpTableInsertWithIdOutcome, WarpTableRow};

#[derive(Debug, Eq, PartialEq)]
#[must_use]
pub enum WarpTableUpsertOutcome<Id, Row: WarpTableRow> {
    Inserted {
        id: Id,
        row: usize,
    },
    Replaced {
        id: Id,
        row: usize,
        previous: Row,
    },
    Full {
        id: Id,
        rejected: Row,
    },
    UniqueConflict {
        id: Id,
        conflict: Row::UniqueConflict,
        rejected: Row,
    },
}

impl<Row: WarpTableRow, Brand> WarpTable<Row, Brand> {
    /// Inserts an absent caller-supplied ID or replaces its existing row.
    pub fn upsert(&mut self, id: Row::Id, row: Row) -> WarpTableUpsertOutcome<Row::Id, Row> {
        match self.insert_with_id(id, row) {
            WarpTableInsertWithIdOutcome::Inserted { id, row } => {
                WarpTableUpsertOutcome::Inserted { id, row }
            }
            WarpTableInsertWithIdOutcome::AlreadyPresent {
                id,
                existing_row,
                rejected: replacement,
            } => match self.replace_at(id, existing_row, replacement) {
                Ok(previous) => WarpTableUpsertOutcome::Replaced {
                    id,
                    row: existing_row,
                    previous,
                },
                Err((conflict, rejected)) => WarpTableUpsertOutcome::UniqueConflict {
                    id,
                    conflict,
                    rejected,
                },
            },
            WarpTableInsertWithIdOutcome::Full { id, rejected } => {
                WarpTableUpsertOutcome::Full { id, rejected }
            }
            WarpTableInsertWithIdOutcome::UniqueConflict {
                id,
                conflict,
                rejected,
            } => WarpTableUpsertOutcome::UniqueConflict {
                id,
                conflict,
                rejected,
            },
        }
    }
}