DataTestIT.java 文件源码

@Test
public void testUpdateAffectPriorityRemotely()
    throws TestFailure, ExecutionException, TimeoutException, InterruptedException {
  List<DatabaseReference> refs = IntegrationTestUtils.getRandomNode(masterApp, 2);
  DatabaseReference reader = refs.get(0);
  DatabaseReference writer = refs.get(1);

  new WriteFuture(writer, new MapBuilder().put("a", 1).put("b", 2).put("c", 3).build(), "testpri")
      .timedGet();

  DataSnapshot snap = TestHelpers.getSnap(reader);
  assertEquals("testpri", snap.getPriority());

  final Semaphore semaphore = new Semaphore(0);
  writer.updateChildren(MapBuilder.of("a", 4),
      new DatabaseReference.CompletionListener() {
        @Override
        public void onComplete(DatabaseError error, DatabaseReference ref) {
          assertNull(error);
          semaphore.release(1);
        }
      });

  TestHelpers.waitFor(semaphore);
  snap = TestHelpers.getSnap(reader);
  assertEquals("testpri", snap.getPriority());
}