1 files changed, 55 insertions, 0 deletions
diff --git a/pulsecaster/pulseaudio/PulseStream.py b/pulsecaster/pulseaudio/PulseStream.py
new file mode 100644
index 0000000..0ebfee9
--- /dev/null
+++ b/pulsecaster/pulseaudio/PulseStream.py
@@ -0,0 +1,55 @@
+#!/usr/bin/python
+# vi: et sw=2
+#
+# PulseSource.py
+# Copyright (C) 2009 Paul W. Frields
+#
+# This program is free software: you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation, either version 3 of the License, or
+# (at your option) any later version.
+#
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+#
+# You should have received a copy of the GNU General Public License
+# along with this program.  If not, see <http://www.gnu.org/licenses/>.
+#
+#
+# Author: Paul W. Frields <stickster@gmail.com>
+#
+
+from lib_pulseaudio import *
+from ctypes import *
+
+from PulseClient import PulseClient
+from PulseVolume import PulseVolumeCtypes
+
+class PulseStream:
+    def __init__(self, context, name, sample_spec, channel_map):
+        self.context = context
+        self.name = name
+        self.sample_spec = sample_spec
+        self.channel_map = channel_map
+        self.data = None
+        self.size = None
+        return
+
+    def connect_record(self, source):
+        retval = pa_stream_connect_record(self,
+                                          source.name,
+                                          None, # buffer_attr
+                                          0) # flags
+        if retval != 0:
+            raise Exception, "Couldn't do connect_record()"
+        
+
+    def peek(self, pulseInterface):
+        pa_stream_peek(self, data, size)
+
+    def disconnect(self):
+        retval = pa_stream_disconnect(self)
+        if retval != 0:
+            raise Exception, "Couldn't do disconnect()"