One camera can now be accessed by two seperate pieces of code. Updated minor version.

displayarray/__init__.py

@@ -4,7 +4,7 @@ Display any array, webcam, or video file.
 display is a function that displays these in their own windows.
 """
 
-__version__ = "1.0.0"
+__version__ = "1.1.0"
 
 from .window.subscriber_windows import display, breakpoint_display, read_updates
 from .frame.frame_publishing import publish_updates_zero_mq, publish_updates_ros

displayarray/frame/frame_publishing.py

@@ -1,11 +1,12 @@
 """Publish frames so any function within this program can find them."""
 
+import asyncio
+import sys
 import threading
 import time
-import asyncio
-import cv2
 import warnings
-import sys
+
+import cv2
 
 using_pyv4l2cam = False
 try:
@@ -123,6 +124,7 @@ def pub_cam_loop_opencv(
     request_size: Tuple[int, int] = (-1, -1),
     high_speed: bool = True,
     fps_limit: float = float("inf"),
+    extra: Optional[List[Tuple[int, int]]] = None,
 ) -> bool:
     """
     Publish whichever camera you select to CVCams.<cam_id>.Vid.
@@ -186,6 +188,9 @@ def pub_cam_loop_opencv(
     return True
 
 
+uid_dict: Dict[str, threading.Thread] = {}
+
+
 def pub_cam_thread(
     cam_id: Union[int, str],
     request_ize: Tuple[int, int] = (-1, -1),
@@ -194,22 +199,27 @@ def pub_cam_thread(
 ) -> threading.Thread:
     """Run pub_cam_loop in a new thread. Starts on creation."""
 
-    if (
-        sys.platform == "linux"
-        and using_pyv4l2cam
-        and (
-            isinstance(cam_id, int)
-            or (isinstance(cam_id, str) and "/dev/video" in cam_id)
-        )
-    ):
-        pub_cam_loop = pub_cam_loop_pyv4l2
+    name = uid_for_source(cam_id)
+    if name in uid_dict.keys():
+        t = uid_dict[name]
     else:
-        pub_cam_loop = pub_cam_loop_opencv
+        if (
+            sys.platform == "linux"
+            and using_pyv4l2cam
+            and (
+                isinstance(cam_id, int)
+                or (isinstance(cam_id, str) and "/dev/video" in cam_id)
+            )
+        ):
+            pub_cam_loop = pub_cam_loop_pyv4l2
+        else:
+            pub_cam_loop = pub_cam_loop_opencv
 
-    t = threading.Thread(
-        target=pub_cam_loop, args=(cam_id, request_ize, high_speed, fps_limit)
-    )
-    t.start()
+        t = threading.Thread(
+            target=pub_cam_loop, args=(cam_id, request_ize, high_speed, fps_limit)
+        )
+        uid_dict[name] = t
+        t.start()
     return t
 
 

displayarray/window/subscriber_windows.py

@@ -211,7 +211,6 @@ class SubscriberWindows(object):
                             self.frames[self.input_vid_global_names[i]][-1] = frame
                 if not self.silent:
                     self.__check_too_many_channels()
-                self.FRAME_DICT[self.input_vid_global_names[i]] = NoData()
         if not self.silent:
             self.display_frames(self.frames)
 

examples/looping/one_cam_two_codes.py

@@ -0,0 +1,10 @@
+from displayarray import read_updates
+
+with read_updates(0) as a, read_updates(0) as b:
+    for i in range(1000):
+        a.update()
+        b.update()
+        try:
+            print(a.frames == b.frames)
+        except ValueError:
+            print(f"frame comparison: {(a.frames['0'][0] == b.frames['0'][0]).all()}")

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = 'displayarray'
-version = '1.0.0'
+version = '1.1.0'
 description = 'Tool for displaying numpy arrays.'
 authors = ['SimLeek <simulator.leek@gmail.com>']
 license = 'MIT'