def connect(&block)
      logger.info("Trying to start telegram-cli and then connect")
      @connect_callback = block
      process_data
      EM.defer(method(:execute), method(:create_pool), method(:execution_failed))
    end
def connect(&block)
      logger.info("Trying to start telegram-cli and then connect")
      @connect_callback = block
      process_data
      EM.defer(method(:execute), method(:create_pool), method(:execution_failed))
    end
Start telegram-cli daemon

 @yield This block will be executed when all connections have responded