pub fn stop(&mut self, id: StreamId) -> Result<bool, UnknownStream> {
        let stream = match self.recv.get_mut(&id) {
            Some(s) => s,
            None => return Err(UnknownStream { _private: () }),
        };
        stream.assembler.stop();
        // Issue flow control credit for unread data
        self.local_max_data += stream.assembler.end() - stream.assembler.bytes_read();
        Ok(!stream.is_finished())
    }
/// Cease accepting data on a stream
///
/// Returns `true` iff the peer should be notified.
Cease accepting data on a stream
Returns `true` iff the peer should be notified.
Cease accepting data on a stream Returns ` true ` iff the peer should be notified .
pub fn stop(&mut self, id: StreamId) -> Result<bool, UnknownStream> {
        let stream = match self.recv.get_mut(&id) {
            Some(s) => s,
            None => return Err(UnknownStream { _private: () }),
        };
        stream.assembler.stop();
        // Issue flow control credit for unread data
        self.local_max_data += stream.assembler.end() - stream.assembler.bytes_read();
        Ok(!stream.is_finished())
    }
pub fn stop ( & mut self , id : StreamId ) -> Result < bool , UnknownStream > { let stream = match self . recv . get_mut ( & id ) { Some ( s ) => s , None => return Err ( UnknownStream { _private : ( ) } ) , } ; stream . assembler . stop ( ) ; // Issue flow control credit for unread data self . local_max_data += stream . assembler . end ( ) - stream . assembler . bytes_read ( ) ; Ok ( ! stream . is_finished ( ) ) }
Cease accepting data on a stream
Returns `true` iff the peer should be notified.
Cease accepting data on a stream Returns ` true ` iff the peer should be notified .
&mut self
id
StreamId