From e0845a0af810aace705146323df7a1ea1fc046d8 Mon Sep 17 00:00:00 2001 From: aler9 <46489434+aler9@users.noreply.github.com> Date: Wed, 25 Nov 2020 21:29:08 +0100 Subject: [PATCH] remove redundant buffer --- internal/client/client.go | 2 +- internal/serverudp/server.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) 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{}), }