func (str *Stream) addSubscriber(eventid string) *Subscriber {
	sub := &Subscriber{
		eventid:    eventid,
		quit:       str.deregister,
		connection: make(chan *Event, 64),
	}

	str.register <- sub
	return sub
}
func (str *Stream) addSubscriber(eventid string) *Subscriber {
	sub := &Subscriber{
		eventid:    eventid,
		quit:       str.deregister,
		connection: make(chan *Event, 64),
	}

	str.register <- sub
	return sub
}
func ( str * Stream ) addSubscriber ( eventid string ) * Subscriber { sub := & Subscriber { eventid : eventid , quit : str . deregister , connection : make ( chan * Event , 64 ) , } str . register <- sub return sub }
// addSubscriber will create a new subscriber on a stream
addSubscriber will create a new subscriber on a stream