取消Close函数

stream/jitter_buffer.go

@@ -61,14 +61,13 @@ func (j *JitterBuffer) Flush() {
 	}
 }
 
-func (j *JitterBuffer) Close() {
-	j.onPacket = nil
+func (j *JitterBuffer) SetHandler(handler func(packet interface{})) {
+	j.onPacket = handler
 }
 
-func NewJitterBuffer(handler func(packet interface{})) *JitterBuffer {
+func NewJitterBuffer() *JitterBuffer {
 	return &JitterBuffer{
 		queue:         make([]interface{}, 0xFFFF+1),
-		onPacket:      handler,
 		minStartCount: 50,
 		first:         true,
 	}

stream/jitterbufer_test.go

@@ -10,7 +10,8 @@ import (
 func TestName(t *testing.T) {
 	// 设置随机数种子，确保每次运行程序时都能得到不同的随机序列
 	rand.Seed(time.Now().UnixNano())
-	buffer := NewJitterBuffer(func(packet interface{}) {
+	buffer := NewJitterBuffer()
+	buffer.SetHandler(func(packet interface{}) {
 		println(packet.(string))
 	})
 
@@ -21,5 +22,4 @@ func TestName(t *testing.T) {
 	}
 
 	buffer.Flush()
-	buffer.Close()
 }