class_docstr: TimeWindowBufer
      
class_docstr_tok: ["TimeWindowBufer"]
code: def _in_test_function(self, time_range, time_step, size):
      buf = _TimeWindowBuffer(time_range, time_step)
      ret = [
          list(range(i, min(i + time_range, size)))
          for i in range(0, size, time_step)
      ]
      data = [(i, i * 1000) for i in range(size)]
      index = 0
      for item in data:
          if buf(item[0], item[1]):
              self.assertEqual(buf.data, ret[index])
              buf = buf.next()
              index += 1
      while buf and buf.data:
          self.assertEqual(buf.data, ret[index])
          buf = buf.next()
          index += 1
  
imports: import unittest
  import copy
  from concurrent.futures import ThreadPoolExecutor
  from towhee.runtime.node_repr import NodeRepr
  from towhee.runtime.nodes import create_node, NodeStatus
  from towhee.runtime.nodes._time_window import _TimeWindowBuffer
  from towhee.runtime.data_queue import DataQueue, ColumnType, Empty
  from towhee.runtime.operator_manager import OperatorPool
label_desc: Use image node_id 1 for calling the TestTimeWindowBuffer obj's underlying member method code with example usage: obj._in_test_function(time_range, time_step, size) without return types