lint

session_test.go

@@ -112,7 +112,7 @@ func TestSpeed(t *testing.T) {
 		}
 		println("total recv:", nrecv)
 		stream.Close()
-		fmt.Println("time for 16MB rtt", time.Now().Sub(start))
+		fmt.Println("time for 16MB rtt", time.Since(start))
 		wg.Done()
 	}()
 	msg := make([]byte, 8192)

stream.go

@@ -125,7 +125,7 @@ func (s *Stream) recycleTokens() (n int) {
 // split large byte buffer into smaller frames, reference only
 func (s *Stream) split(bts []byte, cmd byte, sid uint32) []Frame {
 	var frames []Frame
-	for len(bts) > int(s.frameSize) {
+	for len(bts) > s.frameSize {
 		frame := newFrame(cmd, sid)
 		frame.data = bts[:s.frameSize]
 		bts = bts[s.frameSize:]