(expected *model.MessageExternal)
| 559 | } |
| 560 | |
| 561 | func (c *testingClient) expectMessage(expected *model.MessageExternal) { |
| 562 | select { |
| 563 | case <-time.After(50 * time.Millisecond): |
| 564 | assert.Fail(c.t, "Expected message but none was send :(") |
| 565 | case actual := <-c.readMessage: |
| 566 | assert.Equal(c.t, *expected, actual) |
| 567 | } |
| 568 | } |
| 569 | |
| 570 | func expectMessage(expected *model.MessageExternal, clients ...*testingClient) { |
| 571 | for _, client := range clients { |
no outgoing calls
no test coverage detected