add subscription/channel; notes about CORS

broker/broker.go

@@ -104,6 +104,8 @@ func (b *Broker) HandlerFunc() (http.HandlerFunc, error) {
 		w.Header().Set("Cache-Control", "no-cache")
 		w.Header().Set("Connection", "keep-alive")
 
+		// For CORS stuff please use https://github.com/rs/cors
+
 		// Don't close the connection, instead loop 10 times,
 		// sending messages and flushing the response each time
 		// there is a new message to send along.

subscription/channel.go

@@ -0,0 +1,37 @@
+package subscription
+
+import (
+	"context"
+)
+
+type ChannelSubscription struct {
+	Subscription
+	channel chan string
+}
+
+func NewChannelSubscriptionWithChannel(ctx context.Context, ch chan string) (Subscription, error) {
+
+	sub := &ChannelSubscription{
+		channel: ch,
+	}
+
+	return sub, nil
+}
+
+func (sub *ChannelSubscription) Start(ctx context.Context, messages_ch chan string) error {
+
+	for {
+		select {
+		case <-ctx.Done():
+			return nil
+		case msg := <-sub.channel:
+			messages_ch <- msg
+		}
+	}
+
+	return nil
+}
+
+func (sub *ChannelSubscription) Close() error {
+	return nil
+}