diff --git a/examples/stream/publish/publishAMessage/main.go b/examples/stream/publish/publishAMessage/main.go deleted file mode 100755 index c61f493..0000000 --- a/examples/stream/publish/publishAMessage/main.go +++ /dev/null @@ -1,22 +0,0 @@ -package main - -import ( - "fmt" - "os" - - "go.m3o.com/stream" -) - -// Publish a message to the stream. Specify a topic to group messages for a specific topic. -func main() { - streamService := stream.NewStreamService(os.Getenv("M3O_API_TOKEN")) - rsp, err := streamService.Publish(&stream.PublishRequest{ - Message: map[string]interface{}{ - "id": "1", - "type": "signup", - "user": "john", - }, - Topic: "events", - }) - fmt.Println(rsp, err) -} diff --git a/examples/stream/subscribe/subscribeToATopic/main.go b/examples/stream/subscribe/subscribeToATopic/main.go deleted file mode 100755 index 4c79071..0000000 --- a/examples/stream/subscribe/subscribeToATopic/main.go +++ /dev/null @@ -1,17 +0,0 @@ -package main - -import ( - "fmt" - "os" - - "go.m3o.com/stream" -) - -// Subscribe to messages for a given topic. -func main() { - streamService := stream.NewStreamService(os.Getenv("M3O_API_TOKEN")) - rsp, err := streamService.Subscribe(&stream.SubscribeRequest{ - Topic: "events", - }) - fmt.Println(rsp, err) -}