(outgoing outgoing.Message)
| 15 | } |
| 16 | |
| 17 | func ToTypedOutgoing(outgoing outgoing.Message) (Typed, error) { |
| 18 | payload, err := json.Marshal(outgoing) |
| 19 | if err != nil { |
| 20 | return Typed{}, err |
| 21 | } |
| 22 | return Typed{ |
| 23 | Type: outgoing.Type(), |
| 24 | Payload: payload, |
| 25 | }, nil |
| 26 | } |
| 27 | |
| 28 | func ReadTypedIncoming(r io.Reader) (Event, error) { |
| 29 | typed := Typed{} |