blob: 8f53aca0c09c4994eb9da19cfab143ad81b9089b (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
|
package com.vaadin.tests.push;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import com.vaadin.annotations.Push;
import com.vaadin.server.VaadinRequest;
import com.vaadin.shared.communication.PushMode;
import com.vaadin.shared.ui.ui.Transport;
import com.vaadin.tests.components.AbstractTestUIWithLog;
import com.vaadin.ui.Button;
@Push(value = PushMode.MANUAL, transport = Transport.LONG_POLLING)
public class ManualLongPollingPushUI extends AbstractTestUIWithLog {
ExecutorService executor = Executors.newFixedThreadPool(1);
@Override
protected void setup(VaadinRequest request) {
Button b = new Button("Manual push after 1s",
event -> {
executor.submit(() -> {
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
access(() -> {
log("Logged after 1s, followed by manual push");
push();
});
});
});
addComponent(b);
b = new Button("Double manual push after 1s",
event -> {
executor.submit(() -> {
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
access(() -> {
log("First message logged after 1s, followed by manual push");
push();
log("Second message logged after 1s, followed by manual push");
push();
});
});
});
addComponent(b);
}
}
|
