Method WriteData

go/fory/map.go:63–119

WriteData serializes map data using chunk protocol

(ctx *WriteContext, value reflect.Value)

// WriteData serializes map data using chunk protocol
func (s mapSerializer) WriteData(ctx *WriteContext, value reflect.Value) {
	buf := ctx.Buffer()
	value = unwrapInterface(value)
	length := value.Len()
	buf.WriteVarUint32(uint32(length))
	if length == 0 {
		return
	}

	iter := value.MapRange()
	if !iter.Next() {
		return
	}

	typeResolver := ctx.TypeResolver()
	trackRef := ctx.TrackRef()
	entryKey := unwrapInterface(iter.Key())
	entryVal := unwrapInterface(iter.Value())
	hasNext := true

	for hasNext {
		// Phase 1: Handle null entries (single-item chunks)
		for {
			keyValid := entryKey.IsValid()
			valValid := entryVal.IsValid()

			if keyValid && valValid {
				break // Proceed to regular chunk
			}

			if !keyValid && !valValid {
				buf.WriteInt8(KV_NULL)
			} else if !valValid {
				s.writeNullValueEntry(ctx, entryKey, typeResolver, trackRef)
			} else {
				s.writeNullKeyEntry(ctx, entryVal, typeResolver, trackRef)
			}

			if ctx.HasError() {
				return
			}

			if iter.Next() {
				entryKey = unwrapInterface(iter.Key())
				entryVal = unwrapInterface(iter.Value())
			} else {
				return
			}
		}

		// Phase 2: Write regular chunk with same-type entries
		hasNext = s.writeChunk(ctx, iter, &entryKey, &entryVal, typeResolver, trackRef)
		if ctx.HasError() {
			return
		}
	}
}