/// Absorbs a response, and produces response that should be emitted.
Absorbs a response, and produces response that should be emitted.
Absorbs a response and produces response that should be emitted .
pub fn absorb_response(&mut self, message: ComputeResponse<T>) {
        match message {
            ComputeResponse::FrontierUppers(mut list) => {
                for (id, changes) in list.iter_mut() {
                    if let Some(frontier) = self.uppers.get_mut(id) {
                        let iter = frontier.update_iter(changes.drain());
                        changes.extend(iter);
                    } else {
                        changes.clear();
                    }
                }
                self.responses
                    .push_back(ComputeResponse::FrontierUppers(list));
            }
            ComputeResponse::PeekResponse(uuid, response) => {
                if self.peeks.remove(&uuid) {
                    self.responses
                        .push_back(ComputeResponse::PeekResponse(uuid, response));
                }
            }
            ComputeResponse::TailResponse(id, response) => {
                self.responses
                    .push_back(ComputeResponse::TailResponse(id, response));
            }
        }
    }
pub fn absorb_response ( & mut self , message : ComputeResponse < T > ) { match message { ComputeResponse :: FrontierUppers ( mut list ) => { for ( id , changes ) in list . iter_mut ( ) { if let Some ( frontier ) = self . uppers . get_mut ( id ) { let iter = frontier . update_iter ( changes . drain ( ) ) ; changes . extend ( iter ) ; } else { changes . clear ( ) ; } } self . responses . push_back ( ComputeResponse :: FrontierUppers ( list ) ) ; } ComputeResponse :: PeekResponse ( uuid , response ) => { if self . peeks . remove ( & uuid ) { self . responses . push_back ( ComputeResponse :: PeekResponse ( uuid , response ) ) ; } } ComputeResponse :: TailResponse ( id , response ) => { self . responses . push_back ( ComputeResponse :: TailResponse ( id , response ) ) ; } } }
Absorbs a response, and produces response that should be emitted.
Absorbs a response and produces response that should be emitted .
&mut self
message
ComputeResponse<T>