blob: b1f9ad6200ddf2ff7e209ada995e9576ba4eb2b6 (
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
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
|
package com.vaadin.tests.push;
import java.util.Timer;
import java.util.TimerTask;
import com.vaadin.annotations.Push;
import com.vaadin.server.VaadinRequest;
import com.vaadin.shared.ui.ContentMode;
import com.vaadin.tests.components.AbstractReindeerTestUI;
import com.vaadin.ui.Button;
import com.vaadin.ui.Button.ClickListener;
import com.vaadin.ui.Label;
@Push
public class BasicPush extends AbstractReindeerTestUI {
public static final String CLIENT_COUNTER_ID = "clientCounter";
public static final String STOP_TIMER_ID = "stopTimer";
public static final String START_TIMER_ID = "startTimer";
public static final String SERVER_COUNTER_ID = "serverCounter";
public static final String INCREMENT_BUTTON_ID = "incrementCounter";
private int clientCounter = 0;
private int serverCounter = 0;
private final Timer timer = new Timer(true);
private TimerTask task;
@Override
protected void setup(VaadinRequest request) {
getReconnectDialogConfiguration().setDialogModal(false);
spacer();
/*
* Client initiated push.
*/
Label lbl = new Label("0");
lbl.setCaption("Client counter (click 'increment' to update):");
lbl.setId(CLIENT_COUNTER_ID);
addComponent(lbl);
Button incrementButton = new Button("Increment",
event -> {
clientCounter++;
lbl.setValue(String.valueOf(clientCounter));
});
incrementButton.setId(INCREMENT_BUTTON_ID);
addComponent(incrementButton);
spacer();
/*
* Server initiated push.
*/
Label serverCounterLabel = new Label("0");
serverCounterLabel.setCaption(
"Server counter (updates each 3s by server thread) :");
serverCounterLabel.setId(SERVER_COUNTER_ID);
addComponent(serverCounterLabel);
Button startTimer = new Button("Start timer", (ClickListener) event -> {
serverCounter = 0;
serverCounterLabel.setValue(String.valueOf(serverCounter));
if (task != null) {
task.cancel();
}
task = new TimerTask() {
@Override
public void run() {
access(() -> {
serverCounter++;
serverCounterLabel
.setValue(String.valueOf(serverCounter));
});
}
};
timer.scheduleAtFixedRate(task, 3000, 3000);
});
startTimer.setId(START_TIMER_ID);
addComponent(startTimer);
Button stopTimer = new Button("Stop timer", event -> {
if (task != null) {
task.cancel();
task = null;
}
});
stopTimer.setId(STOP_TIMER_ID);
addComponent(stopTimer);
}
@Override
protected String getTestDescription() {
return "This test tests the very basic operations of push. "
+ "It tests that client initiated changes are "
+ "recieved back to the client as well as server "
+ "initiated changes are correctly updated to the client.";
}
@Override
protected Integer getTicketNumber() {
return 11494;
}
private void spacer() {
addComponent(new Label("<hr/>", ContentMode.HTML));
}
@Override
public void attach() {
super.attach();
}
@Override
public void detach() {
super.detach();
timer.cancel();
}
}
|
