stream.go
func newStream(bufsize int, replay bool) *Stream {
	return &Stream{
		AutoReplay:  replay,
		subscribers: make([]*Subscriber, 0),
		register:    make(chan *Subscriber),
		deregister:  make(chan *Subscriber),
		event:       make(chan *Event, bufsize),
		quit:        make(chan bool),
		Eventlog:    make(EventLog, 0),
	}
}
func newStream(bufsize int, replay bool) *Stream {
	return &Stream{
		AutoReplay:  replay,
		subscribers: make([]*Subscriber, 0),
		register:    make(chan *Subscriber),
		deregister:  make(chan *Subscriber),
		event:       make(chan *Event, bufsize),
		quit:        make(chan bool),
		Eventlog:    make(EventLog, 0),
	}
}
// newStream returns a new stream