diff --git a/internal/client/client.go b/internal/client/client.go index 51c01957..1e173fe7 100644 --- a/internal/client/client.go +++ b/internal/client/client.go @@ -158,7 +158,7 @@ func New( Conn: nconn, ReadTimeout: readTimeout, WriteTimeout: writeTimeout, - ReadBufferCount: 2, + ReadBufferCount: 1, }), parent: parent, state: stateInitial, diff --git a/internal/serverudp/server.go b/internal/serverudp/server.go index 525c772e..b666109a 100644 --- a/internal/serverudp/server.go +++ b/internal/serverudp/server.go @@ -85,7 +85,7 @@ func New(writeTimeout time.Duration, writeTimeout: writeTimeout, streamType: streamType, pc: pc, - readBuf: multibuffer.New(2, readBufferSize), + readBuf: multibuffer.New(1, readBufferSize), publishers: make(map[publisherAddr]*publisherData), done: make(chan struct{}), }