fill prio

2024-04-21 10:51:48 +00:00 · 2019-09-10 20:39:12 +08:00
parent 78fdaa98a6
commit 6284957b0f
1 changed files with 1 additions and 0 deletions
@@ -467,6 +467,7 @@ func (s *Session) writeFrame(f Frame) (n int, err error) {
 // internal writeFrame version to support deadline used in keepalive
 func (s *Session) writeFrameInternal(f Frame, deadline <-chan time.Time, prio uint64) (int, error) {
 	req := writeRequest{
+		prio:   prio,
 		frame:  f,
 		result: make(chan writeResult, 1),
 	}