Method serializeToStream

java/fory-core/src/main/java/org/apache/fory/Fory.java:604–621

(OutputStream outputStream, Consumer<MemoryBuffer> function)

  }

  private void serializeToStream(OutputStream outputStream, Consumer<MemoryBuffer> function) {
    MemoryBuffer buf = getBuffer();
    buf.writerIndex(0);
    function.accept(buf);
    try {
      byte[] bytes = buf.getHeapMemory();
      if (bytes != null) {
        outputStream.write(bytes, 0, buf.writerIndex());
      } else {
        outputStream.write(buf.getBytes(0, buf.writerIndex()));
      }
      outputStream.flush();
    } catch (IOException e) {
      throw new SerializationException(e);
    } finally {
      resetBuffer();
    }
  }

  public MemoryBuffer getBuffer() {
    MemoryBuffer buf = buffer;