fn on_stream_frame(&mut self, notify_readable: bool, stream: StreamId) {
        if stream.initiator() == self.side {
            // Notifying about the opening of locally-initiated streams would be redundant.
            if notify_readable {
                self.events.push_back(StreamEvent::Readable { id: stream });
            }
            return;
        }
        let next = &mut self.next_remote[stream.dir() as usize];
        if stream.index() >= *next {
            *next = stream.index() + 1;
            self.opened[stream.dir() as usize] = true;
        } else if notify_readable {
            self.events.push_back(StreamEvent::Readable { id: stream });
        }
    }
/// Notify the application that new streams were opened or a stream became readable.
Notify the application that new streams were opened or a stream became readable.
Notify the application that new streams were opened or a stream became readable .
fn on_stream_frame(&mut self, notify_readable: bool, stream: StreamId) {
        if stream.initiator() == self.side {
            // Notifying about the opening of locally-initiated streams would be redundant.
            if notify_readable {
                self.events.push_back(StreamEvent::Readable { id: stream });
            }
            return;
        }
        let next = &mut self.next_remote[stream.dir() as usize];
        if stream.index() >= *next {
            *next = stream.index() + 1;
            self.opened[stream.dir() as usize] = true;
        } else if notify_readable {
            self.events.push_back(StreamEvent::Readable { id: stream });
        }
    }
fn on_stream_frame ( & mut self , notify_readable : bool , stream : StreamId ) { if stream . initiator ( ) == self . side { // Notifying about the opening of locally-initiated streams would be redundant. if notify_readable { self . events . push_back ( StreamEvent :: Readable { id : stream } ) ; } return ; } let next = & mut self . next_remote [ stream . dir ( ) as usize ] ; if stream . index ( ) >= * next { * next = stream . index ( ) + 1 ; self . opened [ stream . dir ( ) as usize ] = true ; } else if notify_readable { self . events . push_back ( StreamEvent :: Readable { id : stream } ) ; } }
Notify the application that new streams were opened or a stream became readable.
Notify the application that new streams were opened or a stream became readable .
&mut self
notify_readable
bool
stream
StreamId