From 6284957b0f39e7a3ce9cbcc6311ef39778a8d913 Mon Sep 17 00:00:00 2001
From: xtaci <daniel820313@gmail.com>
Date: Tue, 10 Sep 2019 20:39:12 +0800
Subject: [PATCH] fill prio

---
 session.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/session.go b/session.go
index 580ab1d..99cfce2 100644
--- a/session.go
+++ b/session.go
@@ -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),
 	}