sse test client

main.go

package main

import (
	"github.com/donovanhide/eventsource"
	"fmt"
	"log"
)

func main() {
	// prod
	//serverURL := fmt.Sprintf("http://10.18.32.201:18256")
	//serverURL := fmt.Sprintf("http://staging-johannes194.vip.cf.nr-ops.net")

	// staging
	serverURL := fmt.Sprintf("http://staging-johannes194.vip-dev.cf.nr-ops.net")
	//serverURL := fmt.Sprintf("http://10.11.12.177:28513")

	log.Printf("connecting to %s\n", serverURL)
	stream, err := eventsource.Subscribe(serverURL, "")
	if err != nil {
		log.Fatalf("subscribe: %v", err)
	}

	go func() {
		for err := range stream.Errors {
			log.Printf("received error: %v", err)
		}
		log.Printf("done receiving errors\n")
	}()

	for event := range stream.Events {
		log.Printf("received event: %v", event.Data())
	}

	log.Printf("done\n")
}