code: def combine_from_streaming(
      stream: Iterable[runtime_pb2.Tensor],
  ) -> runtime_pb2.Tensor:
      """Restore a result of split_into_chunks into a single serialized tensor"""
      stream = iter(stream)
      first_chunk = next(stream)
      serialized_tensor = runtime_pb2.Tensor()
      serialized_tensor.CopyFrom(first_chunk)
      buffer_chunks = [first_chunk.buffer]
      for tensor_part in stream:
          buffer_chunks.append(tensor_part.buffer)
      serialized_tensor.buffer = b"".join(buffer_chunks)
      return serialized_tensor
  
imports: from __future__ import annotations
  from typing import Iterable, Iterator
  from hivemind.proto import runtime_pb2
  from hivemind.utils.logging import get_logger
label_desc: Use image node_id 2 for calling a global function with example usage: combine_from_streaming(stream) and returns: serialized_tensor