public void run()

in domain/src/main/java/demoapp/dom/featured/causewayext/sse/DemoTask.java [52:59]


    public void run(final SseChannel eventStream) {                     // <.>
        taskProgress = TaskProgress.of(new LongAdder(), totalSteps);
        for(int i=0; i<totalSteps; ++i) {
            _ThreadSleep.millis(1000);
            taskProgress.getStepsProgressed().increment();
            eventStream.fire(this);                                     // <.>
        }
    }