spatialyze.video_processor.stream.stream.Stream

class documentation

class Stream(Generic[T], ABC):

Known subclasses: spatialyze.video_processor.stream.decode_frame.DecodeFrame, spatialyze.video_processor.stream.deepsort.DeepSORT, spatialyze.video_processor.stream.exit_frame_sampler.ExitFrameSampler, spatialyze.video_processor.stream.from_detection_2d_and_depth.FromDetection2DAndDepth, spatialyze.video_processor.stream.from_detection_2d_and_road.FromDetection2DAndRoad, spatialyze.video_processor.stream.list_images.ListImages, spatialyze.video_processor.stream.load_images.LoadImages, spatialyze.video_processor.stream.mono_depth_estimator.MonoDepthEstimator, spatialyze.video_processor.stream.object_type_pruner.ObjectTypePruner, spatialyze.video_processor.stream.prefilter.Prefilter, spatialyze.video_processor.stream.prune_frames.PruneFrames, spatialyze.video_processor.stream.road_visibility_pruner.RoadVisibilityPruner, spatialyze.video_processor.stream.strongsort.StrongSORT, spatialyze.video_processor.stream.yolo.Yolo

Constructor: Stream(*args, **kwargs)

View In Hierarchy

Undocumented

Method __new__ Undocumented
Method end Undocumented
Method ended Undocumented
Method execute Undocumented
Method iterate Undocumented
Method stream Undocumented
Method _assign_stream_idx Undocumented
Method _free_memory Undocumented
Method _initialize_stream Undocumented
Method _initialize_stream_progress Undocumented
Method _stream Undocumented
Instance Variable _ended Undocumented
Instance Variable _front Undocumented
Instance Variable _iter_stream Undocumented
Instance Variable _results Undocumented
Instance Variable _stream_count Undocumented
Instance Variable _stream_progress Undocumented
Instance Variable _video Undocumented
Instance Variable _visited Undocumented
def __new__(cls, *args, **kwargs):

Undocumented

def end(self):

Undocumented

def ended(self):

Undocumented

def execute(self, video: Video) -> list[T | Skip]:

Undocumented

def iterate(self, video: Video) -> Iterable[T | Skip]:

Undocumented

def stream(self, video: Video) -> Iterable[T | Skip]:

Undocumented

def _assign_stream_idx(self):

Undocumented

def _free_memory(self):

Undocumented

def _initialize_stream(self, video: Video):

Undocumented

def _initialize_stream_progress(self):

Undocumented

@abstractmethod
def _stream(self, video: Video) -> Iterable[T | Skip]:
overridden in spatialyze.video_processor.stream.decode_frame.DecodeFrame, spatialyze.video_processor.stream.deepsort.DeepSORT, spatialyze.video_processor.stream.exit_frame_sampler.ExitFrameSampler, spatialyze.video_processor.stream.from_detection_2d_and_depth.FromDetection2DAndDepth, spatialyze.video_processor.stream.from_detection_2d_and_road.FromDetection2DAndRoad, spatialyze.video_processor.stream.list_images.ListImages, spatialyze.video_processor.stream.load_images.LoadImages, spatialyze.video_processor.stream.mono_depth_estimator.MonoDepthEstimator, spatialyze.video_processor.stream.object_type_pruner.ObjectTypePruner, spatialyze.video_processor.stream.prefilter.Prefilter, spatialyze.video_processor.stream.prune_frames.PruneFrames, spatialyze.video_processor.stream.road_visibility_pruner.RoadVisibilityPruner, spatialyze.video_processor.stream.strongsort.StrongSORT, spatialyze.video_processor.stream.yolo.Yolo

Undocumented

_ended: bool =

Undocumented

_front: int =

Undocumented

_iter_stream: Iterator[T | Skip] | None =

Undocumented

_results: list[T | Skip | None] =

Undocumented

_stream_count: int =

Undocumented

_stream_progress: list[int] =

Undocumented

_video: Video | None =

Undocumented

_visited: bool =

Undocumented