From 1997bc8a150b92783060cc7129e1ee72a761182b Mon Sep 17 00:00:00 2001
From: Kyren223 <ulmliad223@gmail.com>
Date: Sun, 20 Oct 2024 11:36:43 +0300
Subject: refactor: mid refactor

---
 pkg/util/io_test.go | 59 -----------------------------------------------------
 1 file changed, 59 deletions(-)
 delete mode 100644 pkg/util/io_test.go

(limited to 'pkg/util/io_test.go')

diff --git a/pkg/util/io_test.go b/pkg/util/io_test.go
deleted file mode 100644
index f05b833..0000000
--- a/pkg/util/io_test.go
+++ /dev/null
@@ -1,59 +0,0 @@
-package util
-
-import (
-	"bytes"
-	"context"
-	"testing"
-	"time"
-)
-
-func TestChannelReader(t *testing.T) {
-	ctx, cancel := context.WithTimeout(context.Background(), time.Second)
-	defer cancel()
-	b := []byte{1, 2, 3, 4, 5, 6, 7, 8}
-	reader := NewChannelReader(ctx, bytes.NewReader(b))
-
-	select {
-	case data := <-reader.Out:
-		if !bytes.Equal(b, data) {
-			t.Errorf("%v != %v", b, data)
-		}
-	case err := <-reader.Err:
-		t.Errorf("reading err: %v", err)
-	}
-}
-
-func TestChannelReaderMultiPartRead(t *testing.T) {
-	ctx, cancel := context.WithTimeout(context.Background(), time.Second)
-	defer cancel()
-
-	b := []byte("Testing FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting FramerTesting Framer")
-	b1 := b[:512]
-	b2 := b[512:]
-	reader := NewChannelReader(ctx, bytes.NewReader(b))
-
-	counter := 0
-outer:
-	for {
-		select {
-		case data := <-reader.Out:
-			if counter == 0 {
-			if !bytes.Equal(b1, data) {
-				t.Errorf("%v != %v", b, data)
-			}
-			} else {
-				if !bytes.Equal(b2[:len(data)], data) {
-				t.Errorf("%v != %v", b, data)
-			}
-			}
-			counter++
-			if counter == 2 {
-				break outer
-			}
-
-		case err := <-reader.Err:
-			t.Errorf("reading err: %v", err)
-			break outer
-		}
-	}
-}
-- 
cgit v1.3.1