(t *testing.T)
| 38 | } |
| 39 | |
| 40 | func TestProduceSetAddingMessages(t *testing.T) { |
| 41 | _, ps := makeProduceSet() |
| 42 | msg := &ProducerMessage{Key: StringEncoder(TestMessage), Value: StringEncoder(TestMessage)} |
| 43 | |
| 44 | safeAddMessage(t, ps, msg) |
| 45 | |
| 46 | if ps.empty() { |
| 47 | t.Error("set shouldn't be empty when a message is added") |
| 48 | } |
| 49 | |
| 50 | if !ps.readyToFlush() { |
| 51 | t.Error("by default set should be ready to flush when any message is in place") |
| 52 | } |
| 53 | } |
| 54 | |
| 55 | func TestProduceSetAddingMessagesOverflowMessagesLimit(t *testing.T) { |
| 56 | parent, ps := makeProduceSet() |
nothing calls this directly
no test coverage detected