(t *testing.T)
| 233 | } |
| 234 | |
| 235 | func TestRecvChanPanicOnClosedChan(t *testing.T) { |
| 236 | s := RunDefaultServer() |
| 237 | defer s.Shutdown() |
| 238 | |
| 239 | ec := NewEConn(t) |
| 240 | defer ec.Close() |
| 241 | |
| 242 | ch := make(chan int) |
| 243 | |
| 244 | if _, err := ec.BindRecvChan("foo", ch); err != nil { |
| 245 | t.Fatalf("Failed to bind to a send channel: %v\n", err) |
| 246 | } |
| 247 | |
| 248 | close(ch) |
| 249 | ec.Publish("foo", 22) |
| 250 | ec.Flush() |
| 251 | } |
| 252 | |
| 253 | func TestRecvChanAsyncLeakGoRoutines(t *testing.T) { |
| 254 | s := RunDefaultServer() |
nothing calls this directly
no test coverage detected