let estimate = updates.pcs.len() + updates.log.len();
let mut buf = PrepareUpdatesBuffer::new(g, None, Some(estimate));
for (upiece, uuop) in updates.pcs {
- buf.piece_update(upiece, PUO::Simple(uuop));
+ buf.piece_update(upiece, PUOs::Simple(uuop));
}
buf.log_updates(updates.log);
buf.raw_updates(raw);
Bulk(bulk) => {
let mut buf = PrepareUpdatesBuffer::new(g, None, None);
for (upiece, uuop) in bulk.pieces {
- buf.piece_update(upiece, PUO::Simple(uuop));
+ buf.piece_update(upiece, PUOs::Simple(uuop));
}
if bulk.logs {
// updates.rs
pub type PUE = PreparedUpdateEntry;
-pub type PUO = PieceUpdateOps;
+pub type PUO<NS,ZL> = PieceUpdateOp<NS,ZL>;
+pub type PUOs = PieceUpdateOps;
pub type WRC = WhatResponseToClientOp;
}
impl From<PieceUpdateOp<(),()>> for PieceUpdateOps {
- fn from(op: PieceUpdateOp<(),()>) -> Self { PUO::Simple(op) }
+ fn from(op: PieceUpdateOp<(),()>) -> Self { PUOs::Simple(op) }
}
impl From<PieceUpdateFromOpSimple> for PieceUpdate {
-> Result<(),OE> {
let by_client = (WRC::Unpredictable, client, cseq);
let mut buf = PrepareUpdatesBuffer::new(ig, Some(by_client), None);
- let ops = PUO::Simple(PieceUpdateOp::Modify(()));
+ let ops = PUOs::Simple(PieceUpdateOp::Modify(()));
let state = buf.piece_update_fallible(
piece, ops, |pc, gen, _by_client| {
match partially {
let mut out: SecondarySlotMap<PlayerId, PreparedPieceUpdate> = default();
for (player, gpl) in &mut gs.players {
let ops = match ops {
- PUO::Simple(update) => update,
- PUO::PerPlayer(ref ops) => match ops.get(player) {
+ PUOs::Simple(update) => update,
+ PUOs::PerPlayer(ref ops) => match ops.get(player) {
Some(op) => *op,
None => continue,
}