From 98ded8fd9ef299acd4ba8b024574fe1c54466ad7 Mon Sep 17 00:00:00 2001
From: the_fiddler <the_fiddler@ebc5dd9b-fb1d-0410-b6f8-d24c324e9604>
Date: Fri, 4 Apr 2008 21:33:34 +0000
Subject: [PATCH] Moved streaming code to StreamingPlayback.cs.

---
 Source/Examples/OpenAL/Playback.cs          |  4 +--
 Source/Examples/OpenAL/StreamingPlayback.cs | 40 +++++++++++++++++----
 2 files changed, 35 insertions(+), 9 deletions(-)

diff --git a/Source/Examples/OpenAL/Playback.cs b/Source/Examples/OpenAL/Playback.cs
index 48798ae7..270c995d 100644
--- a/Source/Examples/OpenAL/Playback.cs
+++ b/Source/Examples/OpenAL/Playback.cs
@@ -48,8 +48,8 @@ namespace Examples
                 Console.WriteLine();
 
                 AL.SourceStop(source);
-                AL.DeleteSources(ref source);
-                AL.DeleteBuffers(ref buffer);
+                AL.DeleteSource(source);
+                AL.DeleteBuffer(buffer);
 
                 sound.Dispose();
             }
diff --git a/Source/Examples/OpenAL/StreamingPlayback.cs b/Source/Examples/OpenAL/StreamingPlayback.cs
index 4b6d87c3..8edcdd43 100644
--- a/Source/Examples/OpenAL/StreamingPlayback.cs
+++ b/Source/Examples/OpenAL/StreamingPlayback.cs
@@ -37,9 +37,8 @@ namespace Examples.OpenAL
 
                 Console.Write("Playing");
 
-                //new Thread().Start(buffers
-
-
+                SoundStreamer streamer = new SoundStreamer(sound, source, buffers);
+                streamer.Start();
 
                 // Query the source to find out when it stops playing.
                 do
@@ -50,12 +49,13 @@ namespace Examples.OpenAL
                     {
                         AL.GetSource(source, ALGetSourcei.SourceState, out state);
                     }
-                } while ((ALSourceState)state == ALSourceState.Playing);
+                }
+                while ((ALSourceState)state == ALSourceState.Playing);
 
                 Console.WriteLine();
 
                 AL.SourceStop(source);
-                AL.DeleteSources(ref source);
+                AL.DeleteSource(source);
                 AL.DeleteBuffers(buffers);
 
                 sound.Dispose();
@@ -64,9 +64,33 @@ namespace Examples.OpenAL
 
         class SoundStreamer
         {
+            SoundReader reader;
+            int source;
+            int[] buffers;
+
             public SoundStreamer(SoundReader sound, int source, int[] buffers)
             {
-                while (!sound.EndOfFile)
+                reader = sound;
+                this.source = source;
+                this.buffers = buffers;
+
+                lock (openal_lock)
+                {
+                    foreach (int buffer in buffers)
+                        AL.BufferData(buffer, sound.ReadSamples(buffer_size));
+
+                    AL.SourceQueueBuffers(source, buffers.Length, buffers);
+                }
+            }
+
+            public void Start()
+            {
+                new Thread(new ThreadStart(StartStreaming)).Start();
+            }
+
+            void StartStreaming()
+            {
+                while (!reader.EndOfFile)
                 {
                     lock (openal_lock)
                     {
@@ -75,10 +99,12 @@ namespace Examples.OpenAL
                         while (processed_count-- > 0)
                         {
                             int buffer = AL.SourceUnqueueBuffer(source);
-                            AL.BufferData(buffer, sound.ReadSamples(buffer_size));
+                            AL.BufferData(buffer, reader.ReadSamples(buffer_size));
                             AL.SourceQueueBuffer(source, buffer);
                         }
                     }
+
+                    Thread.Sleep(5);
                 }
             }
         }