Method SerializeWithCallback

go/fory/fory.go:695–731

SerializeWithCallback serializes a value to buffer (for streaming/cross-language use). The third parameter is an optional callback for buffer objects (can be nil). If callback is provided, it will be called for each BufferObject during serialization. Return true from callback to write in-band, false

(buffer *ByteBuffer, v any, callback func(BufferObject) bool)

// If callback is provided, it will be called for each BufferObject during serialization.
// Return true from callback to write in-band, false for out-of-band.
func (f *Fory) SerializeWithCallback(buffer *ByteBuffer, v any, callback func(BufferObject) bool) error {
	buf := f.writeCtx.buffer
	defer func() {
		// Reset internal state but NOT the buffer - caller manages buffer state
		// This allows streaming multiple values to the same buffer
		f.writeCtx.ResetState()
		f.writeCtx.buffer = buf
		if f.metaContext != nil {
			f.metaContext.Reset()
		}
		// Set up buffer callback for out-of-band serialization
		if callback != nil {
			f.writeCtx.bufferCallback = nil
			f.writeCtx.outOfBand = false
		}
	}()
	f.writeCtx.buffer = buffer
	if f.metaContext != nil {
		f.metaContext.Reset()
	}
	// Set up buffer callback for out-of-band serialization
	if callback != nil {
		f.writeCtx.bufferCallback = callback
		f.writeCtx.outOfBand = true
	}

	// WriteData protocol header
	writeHeader(f.writeCtx, f.config)

	// Serialize the value - TypeMeta is written inline using streaming protocol
	f.writeCtx.WriteValue(reflect.ValueOf(v), RefModeTracking, true)
	if f.writeCtx.HasError() {
		return f.writeCtx.TakeError()
	}

	return nil
}

// DeserializeWithCallbackBuffers deserializes from buffer into the provided value (for streaming/cross-language use).
// The third parameter is optional external buffers for out-of-band data (can be nil).