Skip to content

Commit f4a87b4

Browse files
feat: add /eventstreams/differentdataschemas endpoint
1 parent 3dc7b02 commit f4a87b4

File tree

2 files changed

+25
-0
lines changed

2 files changed

+25
-0
lines changed

cmd/server/main.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -44,6 +44,7 @@ func main() {
4444
r.HandleFunc("/eventstreams/multiline", eventstreams.HandleEventStreamMultiLine).Methods(http.MethodPost)
4545
r.HandleFunc("/eventstreams/rich", eventstreams.HandleEventStreamRich).Methods(http.MethodPost)
4646
r.HandleFunc("/eventstreams/chat", eventstreams.HandleEventStreamChat).Methods(http.MethodPost)
47+
r.HandleFunc("/eventstreams/differentdataschemas", eventstreams.HandleEventStreamDifferentDataSchemas).Methods(http.MethodPost)
4748

4849
bind := ":8080"
4950
if bindArg != nil {

internal/eventstreams/service.go

Lines changed: 24 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -126,3 +126,27 @@ func HandleEventStreamChat(rw http.ResponseWriter, _ *http.Request) {
126126
},
127127
})
128128
}
129+
130+
func HandleEventStreamDifferentDataSchemas(rw http.ResponseWriter, _ *http.Request) {
131+
rw.Header().Add("Content-Type", "text/event-stream")
132+
133+
pushEvents(rw, [][]string{
134+
{
135+
`id: event-1`,
136+
`event: message`,
137+
`data: {"content": "Here is your url"}`,
138+
},
139+
140+
{
141+
`id: event-2`,
142+
`event: url`,
143+
`data: {"url": "https://example.com"}`,
144+
},
145+
146+
{
147+
`id: event-3`,
148+
`event: message`,
149+
`data: {"content": "Have a great day!"}`,
150+
},
151+
})
152+
}

0 commit comments

Comments
 (0)