code: def end_of_iter_fn(self):
      # with a sync generator, iteration
      assert len(self.requests_handled) == self.num_requests
      assert len(self.results_handled) <= self.num_requests
  
file_path: jina/tests/unit/serve/stream/test_stream.py
imports: import asyncio
  import random
  import pytest
  from docarray import Document, DocumentArray
  from jina.helper import Namespace, random_identity
  from jina.serve.stream import RequestStreamer
  from jina.types.request.data import DataRequest
label_desc: Use image node_id 4 for calling the RequestStreamerWrapper obj's underlying member method code with example usage: obj.end_of_iter_fn() without return types