blob: 2ac83fdb58f9aa6915906376bf5b1841f1a4cf62 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
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;
}
}
}
|
