pub fn handle_dropped_futures(&self) {
        if self.dropped_futures.borrow().is_empty() {
            return;
        }

        self.receive_all();
        let mut buffer = self.buffer.borrow_mut();

        self.dropped_futures.borrow_mut().retain(|id| {
            // Future got invalidated in the meanwhile
            if &id.series != self.current_series.borrow().deref() {
                return false;
            }

            // Clearing response data
            if buffer.is_complete(id.index) {
                buffer.take_frame(id.index);
                return false;
            }

            true
        })
    }
/// Drops response data of dropped futures
Drops response data of dropped futures
Drops response data of dropped futures
pub fn handle_dropped_futures(&self) {
        if self.dropped_futures.borrow().is_empty() {
            return;
        }
        self.receive_all();
        let mut buffer = self.buffer.borrow_mut();
        self.dropped_futures.borrow_mut().retain(|id| {
            // Future got invalidated in the meanwhile
            if &id.series != self.current_series.borrow().deref() {
                return false;
            }
            // Clearing response data
            if buffer.is_complete(id.index) {
                buffer.take_frame(id.index);
                return false;
            }
            true
        })
    }
pub fn handle_dropped_futures ( & self ) { if self . dropped_futures . borrow ( ) . is_empty ( ) { return ; } self . receive_all ( ) ; let mut buffer = self . buffer . borrow_mut ( ) ; self . dropped_futures . borrow_mut ( ) . retain ( | id | { // Future got invalidated in the meanwhile if & id . series != self . current_series . borrow ( ) . deref ( ) { return false ; } // Clearing response data if buffer . is_complete ( id . index ) { buffer . take_frame ( id . index ) ; return false ; } true } ) }
Drops response data of dropped futures
Drops response data of dropped futures
&self
&self