Skip to content

Commit 5400fc6

Browse files
committed
handle multi line messages
1 parent 1464aba commit 5400fc6

3 files changed

Lines changed: 11 additions & 3 deletions

File tree

js/network/onewaydata/changelog.md

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,8 @@
1+
# 6.0.1
2+
3+
* data must be a string
4+
* handle multi line messages
5+
16
# 6.0.0
27

38
* Start Changelog

js/network/onewaydata/examples/server.js

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -54,13 +54,14 @@ console.log(`open http:localhost:${PORT}/`);
5454

5555
let i = 0;
5656
setInterval(() => {
57-
eventStream.send({ data: ++i });
57+
eventStream.send({ data: String(++i) });
5858
}, 1000);
5959

6060
setInterval(() => {
6161
eventStream.send({
6262
event: `football/goal`,
63-
data: `team 1`,
63+
data: `team 1
64+
team 2`,
6465
id: String(Date.now()),
6566
});
6667
}, 5000);

js/network/onewaydata/source/onewaydata.js

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,9 @@ const formatEvent = (x) => {
4646
message = `${message}${EVENT}:${event}\n`;
4747
}
4848
if (data) {
49-
message = `${message}${DATA}:${data}\n`;
49+
data.split(`\n`).filter(Boolean).forEach(line => {
50+
message = `${message}${DATA}:${line}\n`;
51+
});
5052
}
5153
message = `${message}\n`;
5254
return message;

0 commit comments

Comments
 (0)