code: def mocked_worker():
      mocked_core_worker = Mock()
      mocked_core_worker.try_read_next_object_ref_stream.return_value = (
          None
      )
      mocked_core_worker.delete_object_ref_stream.return_value = None
      mocked_core_worker.create_object_ref_stream.return_value = None
      mocked_core_worker.peek_object_ref_stream.return_value = [], []
      worker = MockedWorker(mocked_core_worker)
      yield worker
  
imports: import asyncio
  import pytest
  import numpy
  import sys
  import time
  import threading
  import gc
  from unittest.mock import patch, Mock
  import ray
  from ray._private.test_utils import wait_for_condition
  from ray.experimental.state.api import list_objects
  from ray._raylet import ObjectRefGenerator, ObjectRefStreamEndOfStreamError
  from ray.cloudpickle import dumps
  from ray.exceptions import WorkerCrashedError
label_desc: Use image node_id 1 for calling a global function with example usage: mocked_worker() without return types