Skip to content

Commit cbf4c43

Browse files
author
Mykola Mokhnach
committed
Add missing dependencies
1 parent c76ffc5 commit cbf4c43

File tree

2 files changed

+25
-30
lines changed

2 files changed

+25
-30
lines changed

build.gradle

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,6 @@ dependencies {
6868
force = true
6969
}
7070
compile 'com.google.code.gson:gson:2.8.2'
71-
compile 'javax.websocket:javax.websocket-api:1.1'
7271
compile 'org.apache.httpcomponents:httpclient:4.5.5'
7372
compile 'cglib:cglib:3.2.6'
7473
compile 'commons-validator:commons-validator:1.6'
@@ -77,7 +76,10 @@ dependencies {
7776
compile 'org.springframework:spring-context:5.0.3.RELEASE'
7877
compile 'org.aspectj:aspectjweaver:1.8.13'
7978
compile 'org.openpnp:opencv:3.2.0-1'
80-
79+
compile 'javax.websocket:javax.websocket-api:1.1'
80+
compile 'org.glassfish.tyrus:tyrus-client:1.1'
81+
compile 'org.glassfish.tyrus:tyrus-container-grizzly:1.1'
82+
8183
testCompile 'junit:junit:4.12'
8284
testCompile 'org.hamcrest:hamcrest-all:1.3'
8385
}

src/test/java/io/appium/java_client/android/AndroidLogcatListenerTest.java

Lines changed: 21 additions & 28 deletions
Original file line numberDiff line numberDiff line change
@@ -14,44 +14,37 @@ public class AndroidLogcatListenerTest extends BaseAndroidTest {
1414
@Test
1515
public void verifyLogcatListenerCanBeAssigned() {
1616
final Semaphore messageSemaphore = new Semaphore(1);
17-
final Semaphore connectedSemaphore = new Semaphore(1);
1817
final Duration timeout = Duration.ofSeconds(5);
1918

19+
driver.addLogcatListener(new MessagesHandler<String>() {
20+
@Override
21+
public void onMessage(String message) {
22+
messageSemaphore.release();
23+
}
24+
25+
@Override
26+
public void onConnected() {
27+
System.out.println("Connected to web socket");
28+
}
29+
30+
@Override
31+
public void onDisconnected() {
32+
System.out.println("Disconnected from web socket");
33+
}
34+
35+
@Override
36+
public void onError(Throwable cause) {
37+
cause.printStackTrace();
38+
}
39+
});
2040
try {
2141
driver.startLogcatBroadcast();
22-
driver.addLogcatListener(new MessagesHandler<String>() {
23-
@Override
24-
public void onMessage(String message) {
25-
messageSemaphore.release();
26-
}
27-
28-
@Override
29-
public void onConnected() {
30-
connectedSemaphore.release();
31-
}
32-
33-
@Override
34-
public void onDisconnected() {
35-
// ignore
36-
}
37-
38-
@Override
39-
public void onError(Throwable cause) {
40-
// ignore
41-
}
42-
});
43-
44-
connectedSemaphore.acquire();
4542
messageSemaphore.acquire();
46-
47-
assertTrue(String.format("Didn't connect to the web socket after %s timeout", timeout),
48-
connectedSemaphore.tryAcquire(timeout.toMillis(), TimeUnit.MILLISECONDS));
4943
assertTrue(String.format("Didn't receive any log message after %s timeout", timeout),
5044
messageSemaphore.tryAcquire(timeout.toMillis(), TimeUnit.MILLISECONDS));
5145
} catch (InterruptedException e) {
5246
throw new IllegalStateException(e);
5347
} finally {
54-
connectedSemaphore.release();
5548
messageSemaphore.release();
5649
driver.stopLogcatBroadcast();
5750
}

0 commit comments

Comments
 (0)