TestBeanAdvanced.java 文件源码

@Suppress
public void testFastSerialMessages() throws Exception {
    int times = 100;
    final CountDownLatch testCompletionLatch = new CountDownLatch(times);
    Bean bean = discoverBean();
    synchronousConnect(bean);
    for (int i = 0; i < times; i ++) {
        bean.readLed(new Callback<LedColor>() {
            @Override
            public void onResult(LedColor result) {
                testCompletionLatch.countDown();
            }
        });
    }
    testCompletionLatch.await(120, TimeUnit.SECONDS);
    synchronousDisconnect(bean);
}