(id int)
| 174 | } |
| 175 | |
| 176 | func (o *Oracle) removeSubscriber(id int) { |
| 177 | o.Lock() |
| 178 | defer o.Unlock() |
| 179 | delete(o.subscribers, id) |
| 180 | } |
| 181 | |
| 182 | // sendDeltasToSubscribers reads updates from the o.updates |
| 183 | // constructs a delta object containing transactions from one or more updates |