ambiser
/
openvidu
mirror of https://github.com/OpenVidu/openvidu.git
8
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

openvidu-test-e2e: fix streamPropertyChangedEvent test

pull/621/head
pabloFuente 2021-03-25 12:18:57 +01:00
parent e5a19c78a6
commit eb914b5418
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
openvidu-test-e2e/src/test/java/io/openvidu/test/e2e/OpenViduTestAppE2eTest.java
View File

@ -839,7 +839,7 @@ public class OpenViduTestAppE2eTest extends AbstractOpenViduTestAppE2eTest {
} }
user.getEventManager().off("streamPropertyChanged"); user.getEventManager().off("streamPropertyChanged");
log.info("Thread assertions: {}", threadAssertions.toString()); log.info("Thread assertions for unpublishing video: {}", threadAssertions.toString());
for (Iterator<Boolean> iter = threadAssertions.iterator(); iter.hasNext();) { for (Iterator<Boolean> iter = threadAssertions.iterator(); iter.hasNext();) {
Assert.assertTrue("Some Event property was wrong", iter.next()); Assert.assertTrue("Some Event property was wrong", iter.next());
iter.remove(); iter.remove();
@ -863,6 +863,13 @@ public class OpenViduTestAppE2eTest extends AbstractOpenViduTestAppE2eTest {
return; return;
} }
user.getEventManager().off("streamPropertyChanged");
log.info("Thread assertions for unpublishing audio: {}", threadAssertions.toString());
for (Iterator<Boolean> iter = threadAssertions.iterator(); iter.hasNext();) {
Assert.assertTrue("Some Event property was wrong", iter.next());
iter.remove();
}
// Filter // Filter
final CountDownLatch latch3 = new CountDownLatch(2); final CountDownLatch latch3 = new CountDownLatch(2);
user.getEventManager().on("streamPropertyChanged", (event) -> { user.getEventManager().on("streamPropertyChanged", (event) -> {
@ -890,7 +897,7 @@ public class OpenViduTestAppE2eTest extends AbstractOpenViduTestAppE2eTest {
} }
user.getEventManager().off("streamPropertyChanged"); user.getEventManager().off("streamPropertyChanged");
log.info("Thread assertions: {}", threadAssertions.toString()); log.info("Thread assertions for applying filter: {}", threadAssertions.toString());
for (Iterator<Boolean> iter = threadAssertions.iterator(); iter.hasNext();) { for (Iterator<Boolean> iter = threadAssertions.iterator(); iter.hasNext();) {
Assert.assertTrue("Some Event property was wrong", iter.next()); Assert.assertTrue("Some Event property was wrong", iter.next());
iter.remove(); iter.remove();