(t *testing.T)
| 107 | } |
| 108 | |
| 109 | func TestPipeWriteMultiThread(t *testing.T) { |
| 110 | pReader, pWriter := New(WithSizeLimit(0)) |
| 111 | |
| 112 | var errg errgroup.Group |
| 113 | for i := 0; i < 10; i++ { |
| 114 | errg.Go(func() error { |
| 115 | b := buf.New() |
| 116 | b.WriteString("abcd") |
| 117 | return pWriter.WriteMultiBuffer(buf.MultiBuffer{b}) |
| 118 | }) |
| 119 | } |
| 120 | time.Sleep(time.Millisecond * 100) |
| 121 | pWriter.Close() |
| 122 | errg.Wait() |
| 123 | |
| 124 | b, err := pReader.ReadMultiBuffer() |
| 125 | common.Must(err) |
| 126 | if r := cmp.Diff(b[0].Bytes(), []byte{'a', 'b', 'c', 'd'}); r != "" { |
| 127 | t.Error(r) |
| 128 | } |
| 129 | } |
| 130 | |
| 131 | func TestInterfaces(t *testing.T) { |
| 132 | _ = (buf.Reader)(new(Reader)) |
nothing calls this directly
no test coverage detected