Method onStop

subscriber.go:430–438

(reason *zapcore.Field)

}

func (s *Subscriber) onStop(reason *zapcore.Field) {
	s.StopPlay()
	if !s.Stream.IsClosed() {
		s.Stop(*reason)
		if s.Config.Internal {
			s.Stream.Receive(s.Spesific)
		}
	}
}