From c536782e0167b0b99d589e1161938b6db9d87a47 Mon Sep 17 00:00:00 2001 From: akwizgran Date: Tue, 4 Jun 2019 14:23:47 +0100 Subject: [PATCH] Remove redundant use of IO executor. --- .../contact/ContactExchangeIntegrationTest.java | 12 ++++-------- 1 file changed, 4 insertions(+), 8 deletions(-) diff --git a/bramble-core/src/test/java/org/briarproject/bramble/contact/ContactExchangeIntegrationTest.java b/bramble-core/src/test/java/org/briarproject/bramble/contact/ContactExchangeIntegrationTest.java index 6d1bd9d1a..0409571f9 100644 --- a/bramble-core/src/test/java/org/briarproject/bramble/contact/ContactExchangeIntegrationTest.java +++ b/bramble-core/src/test/java/org/briarproject/bramble/contact/ContactExchangeIntegrationTest.java @@ -172,17 +172,13 @@ public class ContactExchangeIntegrationTest extends BrambleTestCase { alice.getEventBus().addListener(e -> { if (e instanceof ContactAddedEvent) aliceFinished.countDown(); }); - alice.getIoExecutor().execute(() -> - alice.getConnectionManager().manageOutgoingConnection( - bobFromAlice.getId(), DUPLEX_TRANSPORT_ID, - aliceConnection)); + alice.getConnectionManager().manageOutgoingConnection( + bobFromAlice.getId(), DUPLEX_TRANSPORT_ID, aliceConnection); bob.getEventBus().addListener(e -> { if (e instanceof ContactAddedEvent) bobFinished.countDown(); }); - bob.getIoExecutor().execute(() -> - bob.getConnectionManager().manageIncomingConnection( - aliceFromBob.getId(), DUPLEX_TRANSPORT_ID, - bobConnection)); + bob.getConnectionManager().manageIncomingConnection( + aliceFromBob.getId(), DUPLEX_TRANSPORT_ID, bobConnection); assertTrue(aliceFinished.await(TIMEOUT, MILLISECONDS)); assertTrue(bobFinished.await(TIMEOUT, MILLISECONDS)); assertContacts(false, true);