(t *testing.T)
| 185 | } |
| 186 | |
| 187 | func TestForward_RejectsWithoutLoad(t *testing.T) { |
| 188 | g := NewWithT(t) |
| 189 | cp := NewCloudProxy() |
| 190 | c := newInProcClient(t, cp) |
| 191 | stream, err := c.Forward(context.Background()) |
| 192 | g.Expect(err).NotTo(HaveOccurred()) |
| 193 | _ = stream.CloseSend() |
| 194 | _, err = stream.Recv() |
| 195 | g.Expect(err).To(HaveOccurred()) |
| 196 | g.Expect(err.Error()).To(ContainSubstring("not loaded")) |
| 197 | } |
| 198 | |
| 199 | func hasHeader(hs []*pb.ForwardHeader, name, value string) bool { |
| 200 | for _, h := range hs { |
nothing calls this directly
no test coverage detected