Gather 代表的意思是, Producer 透過 多個 Reply 取得 多個 Message 的 response, 其中 Message 和 Reply 是 1 對 1 關聯.

NewMockProducer creates a new mock instance.

NewMux If routeDelimiter is an empty string, Message.RouteParam cannot be used.

Message represents a high-level abstraction data structure containing metadata (e.g.

MockProducer is a mock of Producer interface.

MockProducerMockRecorder is the mock recorder for MockProducer.

MockProducerSendCall wrap *gomock.Call.

MockProducerSendWithCtxCall wrap *gomock.Call.

Mux refers to a router or multiplexer, which can be used to handle different message.

Reply is used to push or pull a response.

go:generate mockgen -typed -package=dataflow -destination=pubsub_mock.go github.com/KScaesar/go-layout/pkg/utility/dataflow Producer.