summaryrefslogtreecommitdiffstats
path: root/plugin/rpcplugin/io_test.go
diff options
context:
space:
mode:
Diffstat (limited to 'plugin/rpcplugin/io_test.go')
-rw-r--r--plugin/rpcplugin/io_test.go73
1 files changed, 0 insertions, 73 deletions
diff --git a/plugin/rpcplugin/io_test.go b/plugin/rpcplugin/io_test.go
deleted file mode 100644
index cb31b23b3..000000000
--- a/plugin/rpcplugin/io_test.go
+++ /dev/null
@@ -1,73 +0,0 @@
-package rpcplugin
-
-import (
- "io/ioutil"
- "os"
- "testing"
- "time"
-
- "github.com/stretchr/testify/assert"
- "github.com/stretchr/testify/require"
-)
-
-func TestNewAsyncReadCloser(t *testing.T) {
- rf, w, err := os.Pipe()
- require.NoError(t, err)
- r := NewAsyncReadCloser(rf)
- defer r.Close()
-
- go func() {
- w.Write([]byte("foo"))
- w.Close()
- }()
-
- foo, err := ioutil.ReadAll(r)
- require.NoError(t, err)
- assert.Equal(t, "foo", string(foo))
-}
-
-func TestNewAsyncReadCloser_CloseDuringRead(t *testing.T) {
- rf, w, err := os.Pipe()
- require.NoError(t, err)
- defer w.Close()
-
- r := NewAsyncReadCloser(rf)
-
- go func() {
- time.Sleep(time.Millisecond * 200)
- r.Close()
- }()
- r.Read(make([]byte, 10))
-}
-
-func TestNewAsyncWriteCloser(t *testing.T) {
- r, wf, err := os.Pipe()
- require.NoError(t, err)
- w := NewAsyncWriteCloser(wf)
- defer w.Close()
-
- go func() {
- foo, err := ioutil.ReadAll(r)
- require.NoError(t, err)
- assert.Equal(t, "foo", string(foo))
- r.Close()
- }()
-
- n, err := w.Write([]byte("foo"))
- require.NoError(t, err)
- assert.Equal(t, 3, n)
-}
-
-func TestNewAsyncWriteCloser_CloseDuringWrite(t *testing.T) {
- r, wf, err := os.Pipe()
- require.NoError(t, err)
- defer r.Close()
-
- w := NewAsyncWriteCloser(wf)
-
- go func() {
- time.Sleep(time.Millisecond * 200)
- w.Close()
- }()
- w.Write(make([]byte, 10))
-}