fixup! fixup! *: add opt-in stream multiplexing support

Author: shubhamdhama

drpcmanager/frame_queue_test.go

@@ -79,4 +79,4 @@ func TestSharedWriteBuf_WaitAndDrainCloseEmpty(t *testing.T) {
 	// Close on empty buffer should return ok=false.
 	sw.Close()
 	<-done
-}
+}

drpcmanager/manager_mux.go

@@ -396,4 +396,4 @@ func (m *MuxManager) NewServerStream(ctx context.Context) (stream *drpcstream.St
 			}
 		}
 	}
-}
+}

drpcmanager/mux_writer.go

@@ -107,4 +107,4 @@ func (sw *sharedWriteBuf) Close() {
 	}
 	sw.closed = true
 	sw.cond.Broadcast()
-}
+}

drpcmanager/mux_writer_test.go

@@ -77,4 +77,4 @@ func TestMuxWriter_WritePacketAfterClose(t *testing.T) {
 
 	err := w.WritePacket(drpcwire.Packet{})
 	assert.Error(t, err)
-}
+}

drpcmanager/registry.go

@@ -86,4 +86,4 @@ func (r *streamRegistry) Len() int {
 	defer r.mu.RUnlock()
 
 	return len(r.streams)
-}
+}

drpcmanager/registry_test.go

@@ -133,4 +133,4 @@ func TestStreamRegistry_ForEach_Empty(t *testing.T) {
 	})
 
 	assert.Equal(t, count, 0)
-}
+}

drpcstream/pktbuf.go

@@ -101,4 +101,4 @@ func (pb *syncPacketBuffer) Done() {
 
 // Recycle is a no-op for syncPacketBuffer. Buffer lifetime is managed by
 // the manageReader goroutine that owns the underlying slice.
-func (pb *syncPacketBuffer) Recycle([]byte) {}
+func (pb *syncPacketBuffer) Recycle([]byte) {}

drpcstream/pktbuf_mux.go

@@ -113,4 +113,4 @@ func (pb *queuePacketBuffer) Recycle(buf []byte) {
 	if buf != nil {
 		recycleToPktBufPool(buf)
 	}
-}
+}