Merge pull request #774 from betcode-org/release/2.6.8

Bump stream id to 10000 to prevent conflicts on multiple restarts

HISTORY.rst

@@ -3,6 +3,13 @@
 Release History
 ---------------
 
+2.6.8 (2024-11-01)
++++++++++++++++++++
+
+**Improvements**
+
+- Bump stream id to 10000 to prevent conflicts on multiple restarts
+
 2.6.7 (2024-11-01)
 +++++++++++++++++++
 

flumine/__version__.py

@@ -1,6 +1,6 @@
 __title__ = "flumine"
 __description__ = "Betting trading framework"
 __url__ = "https://github.com/betcode-org/flumine"
-__version__ = "2.6.7"
+__version__ = "2.6.8"
 __author__ = "Liam Pauling"
 __license__ = "MIT"

flumine/streams/streams.py

@@ -265,7 +265,7 @@ def stop(self) -> None:
             stream.stop()
 
     def _increment_stream_id(self) -> int:
-        self._stream_id += int(1e3)
+        self._stream_id += int(1e4)
         return self._stream_id
 
     def __iter__(self) -> Iterator[Union[MarketStream, DataStream, HistoricalStream]]:

tests/test_streams.py

@@ -452,7 +452,7 @@ def test_stop(self):
         mock_stream.stop.assert_called_with()
 
     def test__increment_stream_id(self):
-        self.assertEqual(self.streams._increment_stream_id(), 1000)
+        self.assertEqual(self.streams._increment_stream_id(), 10000)
 
     def test_iter(self):
         for i in self.streams: