Documentation ¶
Index ¶
- func Send(ch channel2.Channel, msg channel2.TypedMessage) error
- func SendForReply(ch channel2.Channel, msg channel2.TypedMessage, timeout time.Duration) (*channel2.Message, error)
- func SendForReplyAndDecode(ch channel2.Channel, msg channel2.TypedMessage, timeout time.Duration, ...) error
- func SendReply(ch channel2.Channel, sourceMsg *channel2.Message, msg channel2.TypedMessage) error
- func SendReplyWithTimeout(ch channel2.Channel, sourceMessage *channel2.Message, ...) error
- func SendWithTimeout(ch channel2.Channel, msg channel2.TypedMessage, timeout time.Duration) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func SendForReply ¶
func SendForReplyAndDecode ¶
func SendForReplyAndDecode(ch channel2.Channel, msg channel2.TypedMessage, timeout time.Duration, result channel2.TypedMessage) error
func SendReplyWithTimeout ¶
func SendWithTimeout ¶
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.