pub fn send_encoder_updates(&mut self, conn: &mut Connection) -> Res<()> {
        match self.local_stream {
            LocalStreamState::NoStream => {
                qerror!("Send call but there is no stream yet.");
                Ok(())
            }
            LocalStreamState::Uninitialized(stream_id) => {
                let mut buf = QpackData::default();
                buf.encode_varint(QPACK_UNI_STREAM_TYPE_ENCODER);
                if !conn.stream_send_atomic(stream_id, &buf[..])? {
                    return Err(Error::EncoderStreamBlocked);
                }
                self.local_stream = LocalStreamState::Initialized(stream_id);
                self.maybe_send_change_capacity(conn, stream_id)
            }
            LocalStreamState::Initialized(stream_id) => {
                self.maybe_send_change_capacity(conn, stream_id)
            }
        }
    }
/// Sends any qpack encoder instructions.
/// # Errors
///   returns `EncoderStream` in case of an error.
Sends any qpack encoder instructions.
Sends any qpack encoder instructions .
pub fn send_encoder_updates(&mut self, conn: &mut Connection) -> Res<()> {
        match self.local_stream {
            LocalStreamState::NoStream => {
                qerror!("Send call but there is no stream yet.");
                Ok(())
            }
            LocalStreamState::Uninitialized(stream_id) => {
                let mut buf = QpackData::default();
                buf.encode_varint(QPACK_UNI_STREAM_TYPE_ENCODER);
                if !conn.stream_send_atomic(stream_id, &buf[..])? {
                    return Err(Error::EncoderStreamBlocked);
                }
                self.local_stream = LocalStreamState::Initialized(stream_id);
                self.maybe_send_change_capacity(conn, stream_id)
            }
            LocalStreamState::Initialized(stream_id) => {
                self.maybe_send_change_capacity(conn, stream_id)
            }
        }
    }
pub fn send_encoder_updates ( & mut self , conn : & mut Connection ) -> Res < ( ) > { match self . local_stream { LocalStreamState :: NoStream => { qerror ! ( " " ) ; Ok ( ( ) ) } LocalStreamState :: Uninitialized ( stream_id ) => { let mut buf = QpackData :: default ( ) ; buf . encode_varint ( QPACK_UNI_STREAM_TYPE_ENCODER ) ; if ! conn . stream_send_atomic ( stream_id , & buf [ .. ] ) ? { return Err ( Error :: EncoderStreamBlocked ) ; } self . local_stream = LocalStreamState :: Initialized ( stream_id ) ; self . maybe_send_change_capacity ( conn , stream_id ) } LocalStreamState :: Initialized ( stream_id ) => { self . maybe_send_change_capacity ( conn , stream_id ) } } }
Sends any qpack encoder instructions.
Sends any qpack encoder instructions .
&mut self
conn
&mut Connection
errors
returns `EncoderStream` in case of an error.
returns ` EncoderStream ` in case of an error .