Fix transport_mode handling to use config value instead of hardcoded IPC default

- Change _get_publisher signature to require transport_mode parameter
- Update napari_stream.py and fiji_stream.py to use kwargs['transport_mode']
- Remove hardcoded TransportMode.IPC fallbacks

This ensures the platform-aware default from config (TCP on Windows,
IPC on Unix/Mac) is properly used instead of always defaulting to IPC.

Author: trissim

src/polystore/fiji_stream.py

@@ -74,7 +74,7 @@ def save_batch(self, data_list: List[Any], file_paths: List[Union[str, Path]], *
         # Extract kwargs using generic polymorphic names
         host = kwargs.get('host', 'localhost')
         port = kwargs['port']
-        transport_mode = kwargs.get('transport_mode', TransportMode.IPC)
+        transport_mode = kwargs['transport_mode']
         transport_config = kwargs.get('transport_config')
         publisher = self._get_publisher(host, port, transport_mode, transport_config=transport_config)
         display_config = kwargs['display_config']

src/polystore/napari_stream.py

@@ -75,7 +75,7 @@ def save_batch(self, data_list: List[Any], file_paths: List[Union[str, Path]], *
         # Extract kwargs using generic polymorphic names
         host = kwargs.get('host', 'localhost')
         port = kwargs['port']
-        transport_mode = kwargs.get('transport_mode', TransportMode.IPC)
+        transport_mode = kwargs['transport_mode']
         transport_config = kwargs.get('transport_config')
         publisher = self._get_publisher(host, port, transport_mode, transport_config=transport_config)
         display_config = kwargs['display_config']

src/polystore/streaming.py

@@ -57,7 +57,7 @@ def __init__(self, transport_config=None):
         self._shared_memory_blocks = {}
         self._transport_config = transport_config or POLYSTORE_ZMQ_CONFIG
 
-    def _get_publisher(self, host: str, port: int, transport_mode: TransportMode = TransportMode.IPC, transport_config=None):
+    def _get_publisher(self, host: str, port: int, transport_mode: TransportMode, transport_config=None):
         """
         Lazy initialization of ZeroMQ publisher (common for all streaming backends).
 
@@ -67,7 +67,7 @@ def _get_publisher(self, host: str, port: int, transport_mode: TransportMode = T
         Args:
             host: Host to connect to (ignored for IPC mode)
             port: Port to connect to
-            transport_mode: IPC or TCP transport
+            transport_mode: IPC or TCP transport (required - comes from config)
 
         Returns:
             ZeroMQ publisher socket