|
|
|
@ -96,7 +96,7 @@ public class SseEmitterTests { |
|
|
|
public void sendEventFull() throws Exception { |
|
|
|
public void sendEventFull() throws Exception { |
|
|
|
this.emitter.send(event().comment("blah").name("test").reconnectTime(5000L).id("1").data("foo")); |
|
|
|
this.emitter.send(event().comment("blah").name("test").reconnectTime(5000L).id("1").data("foo")); |
|
|
|
this.handler.assertSentObjectCount(3); |
|
|
|
this.handler.assertSentObjectCount(3); |
|
|
|
this.handler.assertObject(0, ":blah\nname:test\nretry:5000\nid:1\ndata:", SseEmitter.TEXT_PLAIN); |
|
|
|
this.handler.assertObject(0, ":blah\nevent:test\nretry:5000\nid:1\ndata:", SseEmitter.TEXT_PLAIN); |
|
|
|
this.handler.assertObject(1, "foo"); |
|
|
|
this.handler.assertObject(1, "foo"); |
|
|
|
this.handler.assertObject(2, "\n\n", SseEmitter.TEXT_PLAIN); |
|
|
|
this.handler.assertObject(2, "\n\n", SseEmitter.TEXT_PLAIN); |
|
|
|
} |
|
|
|
} |
|
|
|
@ -109,7 +109,7 @@ public class SseEmitterTests { |
|
|
|
this.handler.assertObject(1, "foo"); |
|
|
|
this.handler.assertObject(1, "foo"); |
|
|
|
this.handler.assertObject(2, "\ndata:", SseEmitter.TEXT_PLAIN); |
|
|
|
this.handler.assertObject(2, "\ndata:", SseEmitter.TEXT_PLAIN); |
|
|
|
this.handler.assertObject(3, "bar"); |
|
|
|
this.handler.assertObject(3, "bar"); |
|
|
|
this.handler.assertObject(4, "\nname:test\nretry:5000\nid:1\n\n", SseEmitter.TEXT_PLAIN); |
|
|
|
this.handler.assertObject(4, "\nevent:test\nretry:5000\nid:1\n\n", SseEmitter.TEXT_PLAIN); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|