streaming sound buffer consumption tweak

src/Audio/AudioDevice.cs

@@ -1,7 +1,6 @@
 using System;
 using System.Collections.Generic;
 using System.Threading;
-using EasingFunction = System.Func<float, float>;
 
 namespace MoonWorks.Audio
 {

src/Audio/StreamingSound.cs

@@ -10,11 +10,17 @@ namespace MoonWorks.Audio
 	/// </summary>
 	public abstract class StreamingSound : SoundInstance
 	{
+		// How big should each buffer we consume be?
+		protected abstract int BUFFER_SIZE { get; }
+
+		// Are we actively consuming buffers?
+		protected bool ConsumingBuffers = false;
+
 		private const int BUFFER_COUNT = 3;
 		private readonly IntPtr[] buffers;
 		private int nextBufferIndex = 0;
 		private uint queuedBufferCount = 0;
-		protected abstract int BUFFER_SIZE { get; }
+
 		private readonly object StateLock = new object();
 
 		public unsafe StreamingSound(
@@ -54,6 +60,7 @@ namespace MoonWorks.Audio
 
 				State = SoundState.Playing;
 
+				ConsumingBuffers = true;
 				QueueBuffers();
 				FAudio.FAudioSourceVoice_Start(Voice, 0, operationSet);
 			}
@@ -65,6 +72,7 @@ namespace MoonWorks.Audio
 			{
 				if (State == SoundState.Playing)
 				{
+					ConsumingBuffers = false;
 					FAudio.FAudioSourceVoice_Stop(Voice, 0, 0);
 					State = SoundState.Paused;
 				}
@@ -73,6 +81,7 @@ namespace MoonWorks.Audio
 
 		public override void Stop()
 		{
+			ConsumingBuffers = false;
 			State = SoundState.Stopped;
 		}
 
@@ -80,6 +89,7 @@ namespace MoonWorks.Audio
 		{
 			lock (StateLock)
 			{
+				ConsumingBuffers = false;
 				FAudio.FAudioSourceVoice_Stop(Voice, 0, 0);
 				FAudio.FAudioSourceVoice_FlushSourceBuffers(Voice);
 				ClearBuffers();
@@ -114,11 +124,18 @@ namespace MoonWorks.Audio
 
 			queuedBufferCount = state.BuffersQueued;
 
+			if (ConsumingBuffers)
+			{
 				for (int i = 0; i < BUFFER_COUNT - queuedBufferCount; i += 1)
 				{
 					AddBuffer();
 				}
 			}
+			else if (queuedBufferCount == 0)
+			{
+				Stop();
+			}
+		}
 
 		protected unsafe void ClearBuffers()
 		{
@@ -159,15 +176,11 @@ namespace MoonWorks.Audio
 
 				queuedBufferCount += 1;
 			}
-			else if (queuedBufferCount == 0)
-			{
-				// no more data, nothing queued, we're done
-				Stop();
-			}
 
 			if (reachedEnd)
 			{
 				/* We have reached the end of the data, what do we do? */
+				ConsumingBuffers = false;
 				OnReachedEnd();
 			}
 		}

src/Audio/StreamingSoundSeekable.cs

@@ -14,12 +14,9 @@ namespace MoonWorks.Audio
 		{
 			if (Loop)
 			{
+				ConsumingBuffers = true;
 				Seek(0);
 			}
-			else
-			{
-				Stop();
-			}
 		}
 	}
 }