diff options
author | Chris <ccbrown112@gmail.com> | 2017-10-10 14:50:45 -0700 |
---|---|---|
committer | Christopher Speller <crspeller@gmail.com> | 2017-10-10 14:50:45 -0700 |
commit | 66b07a72ce45ce12f1840e0f74f26ea2a9b8105f (patch) | |
tree | 68e4840798360e967770f9cd7315ed123e3547a7 /plugin/rpcplugin/io_test.go | |
parent | f799738613819bd561a65e882c1bc3bb05890850 (diff) | |
download | chat-66b07a72ce45ce12f1840e0f74f26ea2a9b8105f.tar.gz chat-66b07a72ce45ce12f1840e0f74f26ea2a9b8105f.tar.bz2 chat-66b07a72ce45ce12f1840e0f74f26ea2a9b8105f.zip |
remove go 1.8 ipc workaround (#7604)
Diffstat (limited to 'plugin/rpcplugin/io_test.go')
-rw-r--r-- | plugin/rpcplugin/io_test.go | 73 |
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)) -} |