Errors are ignored in `func NewStreamServer(opt Option) *StreamServer` . ``` ss.pubsub.Subscribe(func(payload event.Payload) { ss.payloads <- payload }) ``` If fix this, the public method will be changed.
Errors are ignored in
func NewStreamServer(opt Option) *StreamServer.If fix this, the public method will be changed.