Method dump

python/pyfory/_fory.py:384–412

Serialize an object directly to a writable stream. Args: obj: The object to serialize stream: Writable stream implementing write(...) Notes: The stream must be a non-retaining sink: ``write(data)`` must synchronously consume

(self, obj, stream)

        return self.serialize(obj, buffer, buffer_callback, unsupported_callback)

    def dump(self, obj, stream):
        """
        Serialize an object directly to a writable stream.

        Args:
            obj: The object to serialize
            stream: Writable stream implementing write(...)

        Notes:
            The stream must be a non-retaining sink: ``write(data)`` must
            synchronously consume ``data`` before returning. Fory may reuse or
            modify the underlying buffer after ``write`` returns, so retaining
            the passed object (or a view of it) is unsupported. If your sink
            needs retention, copy bytes inside ``write``.
        """
        try:
            self.buffer.set_writer_index(0)
            output_stream = Buffer.wrap_output_stream(stream)
            self.buffer.bind_output_stream(output_stream)
            self._serialize(
                obj,
                self.buffer,
                buffer_callback=None,
                unsupported_callback=None,
            )
            self.force_flush()
        finally:
            self.buffer.bind_output_stream(None)
            self.reset_write()

    def loads(
        self,