Commit from m3o/m3o action

examples/event/README.md

@@ -34,6 +34,7 @@ Topic: "user",
 
 	})
 	fmt.Println(rsp, err)
+	
 }
 ```
 ## Consume
@@ -56,11 +57,25 @@ import(
 // Consume events from a given topic.
 func ConsumeFromAtopic() {
 	eventService := event.NewEventService(os.Getenv("M3O_API_TOKEN"))
-	rsp, err := eventService.Consume(&event.ConsumeRequest{
+	
+	stream, err := eventService.Consume(&event.ConsumeRequest{
 		Topic: "user",
 
 	})
-	fmt.Println(rsp, err)
+	if err != nil {
+		fmt.Println(err)
+		return
+	}
+
+	for {
+			rsp, err := stream.Recv()
+			if err != nil {
+					fmt.Println(err)
+					return
+			}
+
+			fmt.Println(rsp)
+	}
 }
 ```
 ## Read
@@ -88,5 +103,6 @@ func ReadEventsOnAtopic() {
 
 	})
 	fmt.Println(rsp, err)
+	
 }
 ```

examples/event/publish/publishAnEvent/main.go

@@ -12,9 +12,9 @@ func main() {
 	eventService := event.NewEventService(os.Getenv("M3O_API_TOKEN"))
 	rsp, err := eventService.Publish(&event.PublishRequest{
 		Message: map[string]interface{}{
+			"user": "john",
 			"id":   "1",
 			"type": "signup",
-			"user": "john",
 		},
 		Topic: "user",
 	})