fn open_grease_stream(&mut self, conn: &mut super::Connection) -> Result<()> {
        match self.open_uni_stream(conn, grease_value()) {
            Ok(stream_id) => {
                conn.stream_send(stream_id, b"GREASE is the word", true)?;

                trace!("{} open GREASE stream {}", conn.trace_id(), stream_id);

                qlog_with_type!(QLOG_STREAM_TYPE_SET, conn.qlog, q, {
                    let ev_data = EventData::H3StreamTypeSet(H3StreamTypeSet {
                        stream_id,
                        owner: Some(H3Owner::Local),
                        old: None,
                        new: H3StreamType::Unknown,
                        associated_push_id: None,
                    });

                    q.add_event_data_now(ev_data).ok();
                });
            },

            Err(Error::IdError) => {
                trace!("{} GREASE stream blocked", conn.trace_id(),);

                return Ok(());
            },

            Err(e) => return Err(e),
        };

        Ok(())
    }
/// Opens a new unidirectional stream with a GREASE type and sends some
/// unframed payload.
Opens a new unidirectional stream with a GREASE type and sends some
unframed payload.
Opens a new unidirectional stream with a GREASE type and sends some unframed payload .
fn open_grease_stream(&mut self, conn: &mut super::Connection) -> Result<()> {
        match self.open_uni_stream(conn, grease_value()) {
            Ok(stream_id) => {
                conn.stream_send(stream_id, b"GREASE is the word", true)?;
                trace!("{} open GREASE stream {}", conn.trace_id(), stream_id);
                qlog_with_type!(QLOG_STREAM_TYPE_SET, conn.qlog, q, {
                    let ev_data = EventData::H3StreamTypeSet(H3StreamTypeSet {
                        stream_id,
                        owner: Some(H3Owner::Local),
                        old: None,
                        new: H3StreamType::Unknown,
                        associated_push_id: None,
                    });
                    q.add_event_data_now(ev_data).ok();
                });
            },
            Err(Error::IdError) => {
                trace!("{} GREASE stream blocked", conn.trace_id(),);
                return Ok(());
            },
            Err(e) => return Err(e),
        };
        Ok(())
    }
fn open_grease_stream ( & mut self , conn : & mut super :: Connection ) -> Result < ( ) > { match self . open_uni_stream ( conn , grease_value ( ) ) { Ok ( stream_id ) => { conn . stream_send ( stream_id , b" " , true ) ? ; trace ! ( " " conn trace_id ( ) stream_id ) ; qlog_with_type ! ( QLOG_STREAM_TYPE_SET conn qlog q { let ev_data EventData H3StreamTypeSet ( H3StreamTypeSet { stream_id owner Some ( H3Owner Local ) old None new H3StreamType Unknown associated_push_id None } ) q add_event_data_now ( ev_data ) ok ( ) } ) ; } , Err ( Error :: IdError ) => { trace ! ( " " conn trace_id ( ) ) ; return Ok ( ( ) ) ; } , Err ( e ) => return Err ( e ) , } ; Ok ( ( ) ) }
Opens a new unidirectional stream with a GREASE type and sends some
unframed payload.
Opens a new unidirectional stream with a GREASE type and sends some unframed payload .
&mut self
conn
&mut super::Connection
&mut self
conn
&mut super::Connection