| 715 | } |
| 716 | |
| 717 | func Test_Utils_TestConn_ReadWrite(t *testing.T) { |
| 718 | t.Parallel() |
| 719 | conn := &testConn{} |
| 720 | |
| 721 | // Verify read of request |
| 722 | _, err := conn.r.Write([]byte("Request")) |
| 723 | require.NoError(t, err) |
| 724 | |
| 725 | req := make([]byte, 7) |
| 726 | _, err = conn.Read(req) |
| 727 | require.NoError(t, err) |
| 728 | require.Equal(t, []byte("Request"), req) |
| 729 | |
| 730 | // Verify write of response |
| 731 | _, err = conn.Write([]byte("Response")) |
| 732 | require.NoError(t, err) |
| 733 | |
| 734 | res := make([]byte, 8) |
| 735 | _, err = conn.w.Read(res) |
| 736 | require.NoError(t, err) |
| 737 | require.Equal(t, []byte("Response"), res) |
| 738 | } |
| 739 | |
| 740 | func Test_Utils_TestConn_Closed_Write(t *testing.T) { |
| 741 | t.Parallel() |