@@ -243,7 +243,7 @@ def __init__(self):
243
243
self ._sinks = {} # type: Dict[str, VideoSink]
244
244
self ._tables = {} # type: Dict[int, networktables.NetworkTable]
245
245
# source handle indexed by sink handle
246
- self ._fixedSources = {} # type: Dict[int, int ]
246
+ self ._fixedSources = {} # type: Dict[int, cscore.CvSource ]
247
247
self ._publishTable = NetworkTables .getTable (self .kPublishName )
248
248
self ._nextPort = self .kBasePort
249
249
self ._addresses = []
@@ -376,7 +376,7 @@ def _onTableChange(self, event) -> None:
376
376
return
377
377
378
378
sourceName = relativeKey [:subKeyIndex ]
379
- source = self ._sources .get (sourceName ) # type: VideoSource
379
+ source = self ._sources .get (sourceName ) # type: Optional[ VideoSource]
380
380
if source is None :
381
381
return
382
382
@@ -588,7 +588,7 @@ def getVideo(self, *, name=None, camera=None) -> cscore.CvSink:
588
588
589
589
name = "opencv_" + camera .getName ()
590
590
591
- sink = self ._sinks .get (name ) # type: cscore. VideoSink
591
+ sink = self ._sinks .get (name ) # type: Optional[ VideoSink]
592
592
if sink is not None :
593
593
kind = sink .getKind ()
594
594
if kind != VideoSink .Kind .kCv :
@@ -679,7 +679,7 @@ def removeServer(self, name: str) -> None:
679
679
with self ._mutex :
680
680
self ._sinks .pop (name , None )
681
681
682
- def getServer (self , name : Optional [str ] = None ) -> VideoSink :
682
+ def getServer (self , name : Optional [str ] = None ) -> VideoSource :
683
683
"""Get server by name, or for the primary camera feed if no name is specified.
684
684
685
685
This is only valid to call after a camera feed has been added
0 commit comments