iSharkFly-Docs/java-tutorials
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Complete push example

Browse Source
This commit is contained in:
Marcus Hellberg 2024-03-07 14:07:25 -08:00
parent fcccce33e8
commit 0e34a27d24
1 changed files with 12 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
vaadin/src/main/java/com/baeldung/introduction/PushView.java
View File

@ -1,6 +1,5 @@
package com.baeldung.introduction; package com.baeldung.introduction;
import com.vaadin.flow.component.html.H1;
import com.vaadin.flow.component.html.Span; import com.vaadin.flow.component.html.Span;
import com.vaadin.flow.component.orderedlayout.VerticalLayout; import com.vaadin.flow.component.orderedlayout.VerticalLayout;
import com.vaadin.flow.router.Route; import com.vaadin.flow.router.Route;
@ -16,12 +15,18 @@ public class PushView extends VerticalLayout {
public PushView() { public PushView() {
var output = new Span(); var output = new Span();
add(new H1("Server Push"), output); // Publish server time once a second
var serverTime = Flux.interval(Duration.ofSeconds(1))
.map(o -> "Server time: " + Instant.now());
Flux.interval(Duration.ofSeconds(1))
.map(o -> "Server time: " + Instant.now()) serverTime.subscribe(time ->
.subscribe(time -> getUI().ifPresent(ui -> ui.access(() -> { // ui.access is required to update the UI from a background thread
output.setText(time); getUI().ifPresent(ui ->
}))); ui.access(() -> output.setText(time))
)
);
add(output);
} }
} }