File tree Expand file tree Collapse file tree
src/test/java/com/openfin/desktop Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -289,25 +289,21 @@ public void connectionListener() throws Exception {
289289 CountDownLatch latch = new CountDownLatch (2 );
290290
291291 desktopConnection .getChannel (channelName ).createAsync (AllProtocols ).thenAccept (provider -> {
292- desktopConnection . getChannel ( channelName ). addChannelListener ( new ChannelListener () {
292+ provider . addProviderListener ( new ChannelProviderListener () {
293293 @ Override
294- public void onChannelConnect ( ConnectionEvent connectionEvent ) {
294+ public void onClientConnect ( ChannelClientConnectEvent channelClientConnectEvent ) throws Exception {
295295 latch .countDown ();
296296 }
297-
298297 @ Override
299- public void onChannelDisconnect ( ConnectionEvent connectionEvent ) {
298+ public void onClientDisconnect ( ChannelClientConnectEvent channelClientConnectEvent ) {
300299 latch .countDown ();
301300 }
302301 });
303-
304302 desktopConnection .getChannel (channelName ).connectAsync (null , Channel .RTC_PROTOCOL ).thenAccept (client -> {
305303 client .disconnect ();
306304 });
307305 });
308-
309306 latch .await (10 , TimeUnit .SECONDS );
310-
311307 assertEquals (0 , latch .getCount ());
312308 }
313309
You can’t perform that action at this time.
0 commit comments