fix: issues of post merge review of #106

nominal/core/stream.py

@@ -128,7 +128,7 @@ def process_future(fut: concurrent.futures.Future) -> None:  # type: ignore[type
 
     def _process_timeout_batches(self) -> None:
         while self._running:
-            time.sleep(self.max_wait_sec / 10)
+            time.sleep(1)
             with self._batch_lock:
                 if self._batch and (time.time() - self._last_batch_time) >= self.max_wait_sec:
                     self.flush()