if xupdates.len() != 0 {
Some(
Box::new(move |prepub: &mut PrepareUpdatesBuffer|
- prepub.piece_updates_nc(xupdates))
+ prepub.piece_updates(xupdates, &None))
as SomeUnpreparedUpdates
)
} else { None },
wrc, log,
ops: PUOs::Simple(PUO::Modify(())),
},
- xupdates.into_unprepared_nc())
+ xupdates.into_unprepared(None))
}
fn occultation_notify_hook(&self, piece: PieceId) -> UnpreparedUpdates {
(PieceUpdate {
wrc, log,
ops: PUOs::Simple(PUO::Modify(())),
- }, xupdates.into_unprepared_nc())
+ }, xupdates.into_unprepared(None))
}
}
wrc: WRC::Predictable,
log,
ops: PUOs::PerPlayer(default()),
- }, updates.into_unprepared_nc()))
+ }, updates.into_unprepared(None)))
})() // <- no ?, shows it's infallible
}
self.us.push(PUE::Image(PreparedUpdateEntry_Image { ims }))
}
- pub fn piece_updates_nc(&mut self, updates: Vec<(PieceId, PieceUpdateOps)>) {
+ pub fn piece_updates(&mut self,
+ updates: Vec<(PieceId, PieceUpdateOps)>,
+ by_client: &IsResponseToClientOp) {
for (piece, ops) in updates {
- self.piece_update(piece,&None, ops);
+ self.piece_update(piece, by_client, ops);
}
}
#[ext(pub)]
impl Vec<(PieceId, PieceUpdateOps)> {
- fn into_unprepared_nc(self) -> UnpreparedUpdates {
+ fn into_unprepared(self, by_client: IsResponseToClientOp)
+ -> UnpreparedUpdates {
Some(Box::new(
move |buf: &mut PrepareUpdatesBuffer| {
- buf.piece_updates_nc(self)
+ buf.piece_updates(self, &by_client)
}))
}
}