equal
deleted
inserted
replaced
127 events <- StreamEvent{Event: "error", Error: e} |
127 events <- StreamEvent{Event: "error", Error: e} |
128 continue |
128 continue |
129 } |
129 } |
130 obj = notif |
130 obj = notif |
131 case "delete": |
131 case "delete": |
132 floatPayload, ok := msg.Payload.(float64) |
132 strPayload, ok := msg.Payload.(string) |
133 if !ok { |
133 if !ok { |
134 e := errors.New("could not decode deletion: payload isn't a number") |
134 e := errors.New("could not decode deletion: payload isn't a string") |
135 events <- StreamEvent{Event: "error", Error: e} |
135 events <- StreamEvent{Event: "error", Error: e} |
136 continue |
136 continue |
137 } |
137 } |
138 obj = int64(floatPayload) // statusID |
138 obj = strPayload // statusID |
139 default: |
139 default: |
140 e := errors.Errorf("unhandled event '%s'", msg.Event) |
140 e := errors.Errorf("unhandled event '%s'", msg.Event) |
141 events <- StreamEvent{Event: "error", Error: e} |
141 events <- StreamEvent{Event: "error", Error: e} |
142 continue |
142 continue |
143 } |
143 } |