[undertow-dev] SSE: testing time between events

[Stuart Douglas]

If you want to use a pattern like that you can create another thread
inside the connected() method.

In general though blocking a thread is not a great way to handle this
as you need one thread per connection. You would generally register
the created endpoint somewhere in connected, and then whenever an
event is generated send the message from whatever thread generated the
event.

Stuart

On Tue, May 2, 2017 at 11:19 AM, Ryan Dewell <ryan at dewell.org> wrote:
> OK, on connected I could send say the 10 “events” which occurred since
> “lastEventId”.
>
> Once the connection has been established/connected, where do I send the next
> N events, that maybe occur minutes after the initial “connected”.
>
> In my mind I thought this all occurred inside “connected”.  Meaning
> connected would wait until some new events were available, send those, ad
> infinitum.
>
> Thanks,
>
> Ryan
>
>
> On May 1, 2017, 6:20 PM -0600, Stuart Douglas <sdouglas at redhat.com>, wrote:
>
> When you send you are blocking the IO thread, so the events don't
> actually get put on the wire till the IO thread returns.
>
> Stuart
>
> On Tue, May 2, 2017 at 7:54 AM, Ryan Dewell <ryan at dewell.org> wrote:
>
> Playing around at the moment, and missing something about the threading
> situation as it pertains to sending events.
>
> In my ServerSentEventConnectionCallback:
>
> public void connected(ServerSentEventConnection connection, String
> lastEventId) {
> try {
> for (int i = 0; i<10; i++){
> connection.send("i="+i);
> Thread.sleep(1000);
> }
> } catch (Exception e) {
> throw new RuntimeException(e);
> }
> }
>
> Sending events, with one second between each.
>
> I’d expect the time between events to be reflected in the browser / client.
> However what instead happens is all 10 events arrive within the same
> millisecond (nanoseconds apart according to Chrome console time).
>
> So I’m missing something here. But I don’t see anything obvious. For
> example, there is nothing like a “flush()” on ServerSentEventConnection that
> could be used after each event is sent.
>
> Ideas/guidance?
>
> Thanks!
>
> Ryan
>
>
> _______________________________________________
> undertow-dev mailing list
> undertow-dev at lists.jboss.org
> https://lists.jboss.org/mailman/listinfo/undertow-dev