1 files changed, 60 insertions, 0 deletions
diff --git a/FireBase/Streaming/NonBlockingStreamReader.cs b/FireBase/Streaming/NonBlockingStreamReader.cs
new file mode 100644
index 0000000..2ac83fd
--- /dev/null
+++ b/FireBase/Streaming/NonBlockingStreamReader.cs
@@ -0,0 +1,60 @@
+namespace Firebase.Database.Streaming
+{
+    using System.IO;
+    using System.Text;
+
+    /// <summary>
+    /// When a regular <see cref="StreamReader"/> is used in a UWP app its <see cref="StreamReader.ReadLine"/> method tends to take a long 
+    /// time for data larger then 2 KB. This extremly simple implementation of <see cref="TextReader"/> can be used instead to boost performance
+    /// in your UWP app. Use <see cref="FirebaseOptions"/> to inject an instance of this class into your <see cref="FirebaseClient"/>.
+    /// </summary>
+    public class NonBlockingStreamReader : TextReader
+    {
+        private const int DefaultBufferSize = 16000;
+
+        private readonly Stream stream;
+        private readonly byte[] buffer;
+        private readonly int bufferSize;
+
+        private string cachedData;
+        
+        public NonBlockingStreamReader(Stream stream, int bufferSize = DefaultBufferSize) 
+        {
+            this.stream = stream;
+            this.bufferSize = bufferSize;
+            this.buffer = new byte[bufferSize];
+
+            this.cachedData = string.Empty;
+        }
+
+        public override string ReadLine()
+        {
+            var currentString = this.TryGetNewLine();
+            
+            while (currentString == null)
+            {
+                var read = this.stream.Read(this.buffer, 0, this.bufferSize);
+                var str = Encoding.UTF8.GetString(buffer, 0, read);
+
+                cachedData += str;
+                currentString = this.TryGetNewLine();
+            }
+            
+            return currentString;
+        }
+
+        private string TryGetNewLine()
+        {
+            var newLine = cachedData.IndexOf('\n');
+
+            if (newLine >= 0)
+            {
+                var r = cachedData.Substring(0, newLine + 1);
+                this.cachedData = cachedData.Remove(0, r.Length);
+                return r.Trim();
+            }
+
+            return null;
+        }
+    }
+}