diff --git a/aeron/controlledfragmentassembler.go b/aeron/controlledfragmentassembler.go index 5d5d78a2..f6434d00 100644 --- a/aeron/controlledfragmentassembler.go +++ b/aeron/controlledfragmentassembler.go @@ -74,7 +74,7 @@ func (f *ControlledFragmentAssembler) OnFragment( buffer.WriteBytes(builder, offset, length) if (flags & endFrag) == endFrag { msgLength := builder.Len() - action := f.delegate( + action = f.delegate( atomic.MakeBuffer(builder.Bytes(), msgLength), int32(0), int32(msgLength),