final LinkedBlockingQueue<Boolean> waitConnected = new LinkedBlockingQueue<Boolean>(1);  
boolean result = transportFactory.connect(context, new BTChipTransportFactoryCallback() {  
  
   @Override  
   public void onConnected(boolean success) {  
      try {  
         waitConnected.put(success);  
      } catch (InterruptedException ignore) {  
      }  
   }  
  
});  
if (result) {  
   try {  
      initialized = waitConnected.poll(CONNECT_TIMEOUT, TimeUnit.MILLISECONDS);  
   } catch (InterruptedException ignore) {  
   }  
   if (initialized) {  
      initialized = proxy.init();  
   }  
}