Function safeAddMessage

produce_set_test.go:22–26

(t *testing.T, ps *produceSet, msg *ProducerMessage)

}

func safeAddMessage(t *testing.T, ps *produceSet, msg *ProducerMessage) {
	if err := ps.add(msg); err != nil {
		t.Error(err)
	}
}

func TestProduceSetInitial(t *testing.T) {
	_, ps := makeProduceSet()