(t *testing.T)
| 852 | } |
| 853 | |
| 854 | func (s) TestClientMix(t *testing.T) { |
| 855 | s, ct, cancel := setUp(t, 0, normal) |
| 856 | defer cancel() |
| 857 | time.AfterFunc(time.Second, s.stop) |
| 858 | go func(ct ClientTransport) { |
| 859 | <-ct.Error() |
| 860 | ct.Close(fmt.Errorf("closed manually by test")) |
| 861 | }(ct) |
| 862 | for i := 0; i < 750; i++ { |
| 863 | time.Sleep(2 * time.Millisecond) |
| 864 | go performOneRPC(ct) |
| 865 | } |
| 866 | } |
| 867 | |
| 868 | func (s) TestLargeMessage(t *testing.T) { |
| 869 | server, ct, cancel := setUp(t, 0, normal) |
nothing calls this directly
no test coverage detected