summaryrefslogtreecommitdiffstats
path: root/plugin/rpcplugin/io_test.go
diff options
context:
space:
mode:
authorChris <ccbrown112@gmail.com>2017-10-10 14:50:45 -0700
committerChristopher Speller <crspeller@gmail.com>2017-10-10 14:50:45 -0700
commit66b07a72ce45ce12f1840e0f74f26ea2a9b8105f (patch)
tree68e4840798360e967770f9cd7315ed123e3547a7 /plugin/rpcplugin/io_test.go
parentf799738613819bd561a65e882c1bc3bb05890850 (diff)
downloadchat-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.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))
-}