From 66b07a72ce45ce12f1840e0f74f26ea2a9b8105f Mon Sep 17 00:00:00 2001 From: Chris Date: Tue, 10 Oct 2017 14:50:45 -0700 Subject: remove go 1.8 ipc workaround (#7604) --- plugin/rpcplugin/io_test.go | 73 --------------------------------------------- 1 file changed, 73 deletions(-) delete mode 100644 plugin/rpcplugin/io_test.go (limited to 'plugin/rpcplugin/io_test.go') 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)) -} -- cgit v1.2.3-1-g7c22