Method Subscribe

subscriber.go:138–140

(streamPath string, sub ISubscriber)

}

func (s *Subscriber) Subscribe(streamPath string, sub ISubscriber) error {
	return s.receive(streamPath, sub)
}

func (s *Subscriber) GetSubscriber() *Subscriber {
	return s