From 45d3c6a79193878aeea344c48b5d18ee128fb087 Mon Sep 17 00:00:00 2001 From: Asim Aslam Date: Thu, 18 Nov 2021 08:32:29 +0000 Subject: [PATCH] remove broken examples --- .../stream/publish/publishAMessage/main.go | 22 ------------------- .../subscribe/subscribeToATopic/main.go | 17 -------------- 2 files changed, 39 deletions(-) delete mode 100755 examples/stream/publish/publishAMessage/main.go delete mode 100755 examples/stream/subscribe/subscribeToATopic/main.go 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) -}