From 3b5a498aa5751b1a21a1002307162c77fcae64ff Mon Sep 17 00:00:00 2001 From: Sasha Koshka Date: Wed, 19 Nov 2025 15:16:44 -0500 Subject: [PATCH] Do not send extraneous chained MMBs --- metadapta.go | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/metadapta.go b/metadapta.go index 9b35d1d..e7feda7 100644 --- a/metadapta.go +++ b/metadapta.go @@ -425,7 +425,9 @@ func (this *writerA) Write(data []byte) (n int, err error) { } func (this *writerA) Close() error { - this.flush(0) + if len(this.buffer) > 0 { + this.flush(0) + } this.open = false return nil } @@ -453,7 +455,9 @@ func (this *writerA) writeOne(data []byte) (n int, err error) { } func (this *writerA) flush(ccb uint64) error { - return this.parent.parent.sendMessageSafe(this.parent.id, this.method, ccb, this.buffer) + err := this.parent.parent.sendMessageSafe(this.parent.id, this.method, ccb, this.buffer) + this.buffer = this.buffer[0:0] + return err } type incomingMessage struct {