Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type InnerMessage ¶
type InnerMessage struct {
Envelope *message.Envelope
OnErr func(error)
OnSuccess func(interface{})
}
type OutterMessage ¶
type OutterMessage struct {
Envelope *message.Envelope
Message *message.StreamMessage
ConnectionID string
Conn connection
sync.Mutex
}
func (*OutterMessage) Respond ¶
func (m *OutterMessage) Respond(envelope *message.Envelope, successCallBack func(interface{}), errCallBack func(error))
Respond sends a msg to the source that sent the ReceivedMessageImpl
Source Files
Click to show internal directories.
Click to hide internal directories.