code: func (a *Aggregator) ReadAndSubscribe(id string, msgc chan<- *rfc5424.Message, donec <-chan struct{}) []*rfc5424.Message {
  	return a.getBuffer(id).ReadAndSubscribe(msgc, donec)
  }
docs: // Read returns the buffered messages and adds a subscriber channel for id.