rwf2
/
Rocket
mirror of https://github.com/rwf2/Rocket.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Ignore heartbeats in non-heartbeat SSE test.

This commit is contained in:
Sergio Benitez 2021-06-09 04:48:49 -07:00
parent 32ec00ca19
commit 1aa551ada6
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
core/lib/src/response/stream/sse.rs
View File

@ -699,20 +699,20 @@ mod sse_tests {
use futures::stream::iter;
let stream = EventStream::from(iter(vec![Event::data("foo")]));
assert_eq!(stream.into_string(), "data:foo\n\n");
assert_eq!(stream.into_string().replace(":\n\n", ""), "data:foo\n\n");
let stream = EventStream::from(iter(vec![Event::data("a"), Event::data("b")]));
assert_eq!(stream.into_string(), "data:a\n\ndata:b\n\n");
assert_eq!(stream.into_string().replace(":\n\n", ""), "data:a\n\ndata:b\n\n");
let stream = EventStream::from(iter(vec![
Event::data("a\n"),
Event::data("a\nb"),
Event::data("b"),
Event::data("c\n\nd"),
Event::data("e"),
]));
assert_eq!(stream.into_string(),
"data:a\ndata:\n\ndata:b\n\ndata:c\ndata:\ndata:d\n\ndata:e\n\n");
assert_eq!(stream.into_string().replace(":\n\n", ""),
"data:a\ndata:b\n\ndata:b\n\ndata:c\ndata:\ndata:d\n\ndata:e\n\n");
}
#[test]