From 7bde8bbb733dfcba7baace5c2261f67da8e0d3d0 Mon Sep 17 00:00:00 2001 From: cyBerta Date: Sun, 7 Nov 2021 05:20:25 +0100 Subject: Add provider setup unit tests wrt. Tor handling --- .../main/java/se/leap/bitmaskclient/tor/TorStatusObservable.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) (limited to 'app/src/main/java/se/leap/bitmaskclient/tor') diff --git a/app/src/main/java/se/leap/bitmaskclient/tor/TorStatusObservable.java b/app/src/main/java/se/leap/bitmaskclient/tor/TorStatusObservable.java index 3be4ce12..fae7d063 100644 --- a/app/src/main/java/se/leap/bitmaskclient/tor/TorStatusObservable.java +++ b/app/src/main/java/se/leap/bitmaskclient/tor/TorStatusObservable.java @@ -83,8 +83,9 @@ public class TorStatusObservable extends Observable { * @param timeout Timout in seconds * @throws InterruptedException if thread was interrupted while waiting * @throws TimeoutException thrown if timeout was reached + * @return true return value only needed to mock this method call */ - public static void waitUntil(StatusCondition condition, int timeout) throws InterruptedException, TimeoutException { + public static boolean waitUntil(StatusCondition condition, int timeout) throws InterruptedException, TimeoutException { CountDownLatch countDownLatch = new CountDownLatch(1); final AtomicBoolean conditionMet = new AtomicBoolean(false); Observer observer = (o, arg) -> { @@ -95,7 +96,7 @@ public class TorStatusObservable extends Observable { }; if (condition.met()) { // no need to wait - return; + return true; } getInstance().addObserver(observer); countDownLatch.await(timeout, TimeUnit.SECONDS); @@ -103,6 +104,7 @@ public class TorStatusObservable extends Observable { if (!conditionMet.get()) { throw new TimeoutException("Status condition not met within " + timeout + "s."); } + return true; } public static void logSnowflakeMessage(Context context, String message) { -- cgit v1.2.3