code: def collect_streamable_data(
      encoded_tree: Iterator[Tuple[bytes, bytes]]
  ) -> bytes:
      result = [
          struct.pack("I", len(key))
          + key
          + struct.pack("I", len(val))
          + val
          for key, val in encoded_tree
      ]
      return b"".join(result)
  
imports: import asyncio
  import numpy
  import random
  import struct
  import time
  from collections import namedtuple
  from itertools import chain
  from typing import Iterator, Tuple, Optional, List
  from typing import TYPE_CHECKING
  from fastapi import HTTPException
  from aim.storage.context import Context
  from aim.sdk import Run
  from aim.sdk.sequences.metric import Metric
  from aim.sdk.sequence_collection import SequenceCollection
  from aim.storage.query import syntax_error_check
  from aim.web.configs import AIM_PROGRESS_REPORT_INTERVAL
  from aim.web.api.projects.project import Project
  from aim.web.api.runs.pydantic_models import AlignedRunIn, TraceBase
  from aim.storage.treeutils import encode_tree
label_desc: Use image node_id 8 for calling a global function with example usage: collect_streamable_data(encoded_tree) and returns: bytes