@@ -157,8 +157,10 @@ public Object call() throws Exception {
157157 log .setDecoupler (decoupler );
158158 decoupler .start ();
159159 decoupler .getUpdateListener ().accept (PVEvent .readConnectionEvent ());
160+ Thread .sleep (50 );
161+ decoupler .getUpdateListener ().accept (PVEvent .readConnectionEvent ());
160162 decoupler .getUpdateListener ().accept (PVEvent .valueEvent ());
161- Thread .sleep (100 );
163+ Thread .sleep (150 );
162164 decoupler .getUpdateListener ().accept (PVEvent .valueEvent ());
163165 Thread .sleep (1 );
164166 decoupler .getUpdateListener ().accept (PVEvent .valueEvent ());
@@ -177,10 +179,11 @@ public Object call() throws Exception {
177179 Thread .sleep (150 );
178180 decoupler .stop ();
179181 // 3 events: connection, first value, last value
180- assertThat (log .getEvents ().size (), equalTo (3 ));
181- assertThat (log .getEvents ().get (0 ).getType (), equalTo (Arrays .asList (PVEvent .Type .READ_CONNECTION , PVEvent . Type . VALUE )));
182- assertThat (log .getEvents ().get (1 ).getType (), equalTo (Arrays .asList (PVEvent .Type .VALUE )));
182+ assertThat (log .getEvents ().size (), equalTo (4 ));
183+ assertThat (log .getEvents ().get (0 ).getType (), equalTo (Arrays .asList (PVEvent .Type .READ_CONNECTION )));
184+ assertThat (log .getEvents ().get (1 ).getType (), equalTo (Arrays .asList (PVEvent .Type .READ_CONNECTION , PVEvent . Type . VALUE )));
183185 assertThat (log .getEvents ().get (2 ).getType (), equalTo (Arrays .asList (PVEvent .Type .VALUE )));
186+ assertThat (log .getEvents ().get (3 ).getType (), equalTo (Arrays .asList (PVEvent .Type .VALUE )));
184187 return null ;
185188 }
186189 });
0 commit comments