Flush on stream encode

This commit is contained in:
DataHoarder 2022-11-11 10:43:13 +01:00
parent 446a2a75dc
commit ace16a6b6a
Signed by: DataHoarder
SSH key fingerprint: SHA256:OLTRf6Fl87G52SiR7sWLGNzlJt4WOX+tfI2yxo0z7xk
2 changed files with 2 additions and 2 deletions

View file

@ -195,7 +195,7 @@ func (e *Encoder) EncodeStream(stream *frame.Stream) error {
return err
}
}
return nil
return e.Flush()
}
func (e *Encoder) Encode(f frame.Frame) error {

View file

@ -163,7 +163,7 @@ func (e *Encoder) EncodeStream(stream *frame.Stream) error {
return err
}
}
return nil
return e.Flush()
}
func (e *Encoder) Encode(f frame.Frame) error {