diff --git a/go.mod b/go.mod index aa376f2..75114f0 100644 --- a/go.mod +++ b/go.mod @@ -1,4 +1,4 @@ -module github.com/r3labs/sse/v2 +module github.com/nofik44/sse go 1.13 diff --git a/subscriber.go b/subscriber.go index 4b54c20..16e3c7d 100644 --- a/subscriber.go +++ b/subscriber.go @@ -22,3 +22,8 @@ func (s *Subscriber) close() { <-s.removed } } + +// Send individual message +func (s *Subscriber) Send(event *Event) { + s.connection <- event +}