aboutsummaryrefslogtreecommitdiff
path: root/v_windows/v/old/vlib/io/reader_test.v
diff options
context:
space:
mode:
Diffstat (limited to 'v_windows/v/old/vlib/io/reader_test.v')
-rw-r--r--v_windows/v/old/vlib/io/reader_test.v130
1 files changed, 130 insertions, 0 deletions
diff --git a/v_windows/v/old/vlib/io/reader_test.v b/v_windows/v/old/vlib/io/reader_test.v
new file mode 100644
index 0000000..c7a2265
--- /dev/null
+++ b/v_windows/v/old/vlib/io/reader_test.v
@@ -0,0 +1,130 @@
+module io
+
+struct Buf {
+pub:
+ bytes []byte
+mut:
+ i int
+}
+
+fn (mut b Buf) read(mut buf []byte) ?int {
+ if !(b.i < b.bytes.len) {
+ return none
+ }
+ n := copy(buf, b.bytes[b.i..])
+ b.i += n
+ return n
+}
+
+fn test_read_all() {
+ buf := Buf{
+ bytes: '123'.repeat(10).bytes()
+ }
+ res := read_all(reader: buf) or {
+ assert false
+ ''.bytes()
+ }
+ assert res == '123'.repeat(10).bytes()
+}
+
+fn test_read_all_huge() {
+ buf := Buf{
+ bytes: '123'.repeat(100000).bytes()
+ }
+ res := read_all(reader: buf) or {
+ assert false
+ ''.bytes()
+ }
+ assert res == '123'.repeat(100000).bytes()
+}
+
+struct StringReader {
+ text string
+mut:
+ place int
+}
+
+fn (mut s StringReader) read(mut buf []byte) ?int {
+ if s.place >= s.text.len {
+ return none
+ }
+ read := copy(buf, s.text[s.place..].bytes())
+ s.place += read
+ return read
+}
+
+const (
+ newline_count = 100000
+)
+
+fn test_stringreader() {
+ text := '12345\n'.repeat(io.newline_count)
+ mut s := StringReader{
+ text: text
+ }
+ mut r := new_buffered_reader(reader: s)
+ for i := 0; true; i++ {
+ if _ := r.read_line() {
+ } else {
+ assert i == io.newline_count
+ break
+ }
+ }
+ if _ := r.read_line() {
+ assert false
+ }
+ leftover := read_all(reader: r) or {
+ assert false
+ panic('bad')
+ }
+ if leftover.len > 0 {
+ assert false
+ }
+}
+
+fn test_stringreader2() {
+ text := '12345\r\n'.repeat(io.newline_count)
+ mut s := StringReader{
+ text: text
+ }
+ mut r := new_buffered_reader(reader: s)
+ for i := 0; true; i++ {
+ if _ := r.read_line() {
+ } else {
+ assert i == io.newline_count
+ break
+ }
+ }
+ if _ := r.read_line() {
+ assert false
+ }
+ leftover := read_all(reader: r) or {
+ assert false
+ panic('bad')
+ }
+ if leftover.len > 0 {
+ assert false
+ }
+}
+
+fn test_leftover() {
+ text := 'This is a test\r\nNice try!'
+ mut s := StringReader{
+ text: text
+ }
+ mut r := new_buffered_reader(reader: s)
+ _ := r.read_line() or {
+ assert false
+ panic('bad')
+ }
+ line2 := r.read_line() or {
+ assert false
+ panic('bad')
+ }
+ assert line2 == 'Nice try!'
+ if _ := r.read_line() {
+ assert false
+ panic('bad')
+ }
+ assert r.end_of_stream()
+}