I want the AMQP transport package to provide a client-side request/response publisher API for invoking…
I want the AMQP transport package to provide a client-side request/response publisher API for invoking…: a task in MiMo-V2.6-RL-oss: Agentic RL Environments (MiMo RL release). The public constructor should be NewPublisher(ch Channel, q amqp.Queue, enc EncodeRequestFunc, dec DecodeResponseFunc…
The task
The public constructor should be NewPublisher(ch Channel, q amqp.Queue, enc EncodeRequestFunc, dec DecodeResponseFunc, options ...PublisherOption) Publisher, where EncodeRequestFunc writes the domain request into an amqp.Publishing and DecodeResponseFunc converts the matching…
Part of XiaomiMiMo/MiMo-V2.6-RL-oss.