save filter

bob/io/stream/stream.py

@@ -425,4 +425,19 @@ class StreamAdjust(StreamFilter):
             print(new_indices)
             print(self.parent.timestamps)
             print(self.adjust_to.timestamps)
-        return super().load(new_indices)
\ No newline at end of file
+        return super().load(new_indices)
+
+################################################################################
+### save ###
+@stream_filter("save")
+class StreamAdjust(StreamFilter):
+    def __init__(self, file, name, parent):
+        super().__init__(name=name, parent=parent)
+        self.file = file
+
+    def put(self, data, timestamp=None):
+        if self.file is not None and isinstance(file, StreamFile):
+            self.file.put_frame(self.name, data)
+        else:
+            raise(Exception('save: file is not defined'))
+        return data
\ No newline at end of file