Method DeserializeWithCallbackBuffers

go/fory/fory.go:735–776

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).

(buffer *ByteBuffer, v any, buffers []*ByteBuffer)

// 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).
func (f *Fory) DeserializeWithCallbackBuffers(buffer *ByteBuffer, v any, buffers []*ByteBuffer) error {
	// Reset context and use the provided buffer
	f.readCtx.buffer = buffer
	defer func() {
		f.readCtx.Reset()
		if f.metaContext != nil {
			f.metaContext.Reset()
		}
		f.readCtx.buffer = nil
		f.readCtx.outOfBandBuffers = nil
	}()
	// Set up out-of-band buffers if provided
	if buffers != nil {
		f.readCtx.outOfBandBuffers = buffers
	}

	// ReadData and validate header
	readHeader(f.readCtx)
	if f.readCtx.HasError() {
		return f.readCtx.TakeError()
	}

	// v must be a pointer so we can deserialize into it
	if v == nil {
		return fmt.Errorf("v cannot be nil")
	}
	rv := reflect.ValueOf(v)
	if rv.Kind() != reflect.Ptr {
		return fmt.Errorf("v must be a pointer, got %v", rv.Kind())
	}
	if rv.IsNil() {
		return fmt.Errorf("v must be a non-nil pointer")
	}

	// Deserialize the value - TypeMeta is read inline using streaming protocol
	f.readCtx.ReadValue(rv.Elem(), RefModeTracking, true)
	if f.readCtx.HasError() {
		return f.readCtx.TakeError()
	}

	return nil
}

// serializeReflectValue serializes a reflect.Value directly, avoiding boxing overhead.
// This is used by Serialize[T] fallback path to avoid struct copy.