Examples of tick()


Examples of com.collective2.signalEntry.adapter.DynamicSimulationAdapter.tick()

        simulationAdapter.tick(dataProvider,sentryService);

        assertEquals(10, portfolio.position("msft").quantity().intValue());

        dataProvider = dataProvider.incTime(timeStep,new BigDecimal("22"));
        simulationAdapter.tick(dataProvider,sentryService);

        assertEquals(10, portfolio.position("msft").quantity().intValue());

        final Set<Integer> pendingSignalIdSet = new HashSet<Integer>();
        sentryService.sendAllSignalsRequest().visitC2Elements(new C2ElementVisitor() {
View Full Code Here

Examples of com.collective2.signalEntry.adapter.DynamicSimulationAdapter.tick()

        BigDecimal closePrice = new BigDecimal("160.86");
        BigDecimal lowPrice = new BigDecimal("80");
        BigDecimal highPrice = new BigDecimal("100");
        DynamicSimulationMockDataProvider dataProvider = new DynamicSimulationMockDataProvider(
                openTime,lowPrice,highPrice,lowPrice,highPrice,closeTime);
        simulationAdapter.tick(dataProvider,sentryService);

        assertEquals(10, portfolio.position("msft").quantity().intValue());

        //confirm that a price below target will not trigger
        dataProvider = dataProvider.incTime(timeStep,new BigDecimal("119"));
View Full Code Here

Examples of com.collective2.signalEntry.adapter.DynamicSimulationAdapter.tick()

        assertEquals(10, portfolio.position("msft").quantity().intValue());

        //confirm that a price below target will not trigger
        dataProvider = dataProvider.incTime(timeStep,new BigDecimal("119"));
        simulationAdapter.tick(dataProvider,sentryService);

        assertEquals(10, portfolio.position("msft").quantity().intValue());

        final Set<Integer> pendingSignalIdSet = new HashSet<Integer>();
        sentryService.sendAllSignalsRequest().visitC2Elements(new C2ElementVisitor() {
View Full Code Here

Examples of com.collective2.signalEntry.adapter.dynamicSimulator.SystemManager.tick()

        //can not tick and transmit at same moment in order to keep simulator repeatable
        synchronized(lock) {
               //look at ordered list of signals for each system and do all those older than time now.
            this.time = dataProvider.endingTime();
            system.tick(time, dataProvider);
            lastTickDataProvider = dataProvider;
        }

        for(GainListenerManager manager:gainListeners) {
            manager.send(gainExecutor, dataProvider, system);
View Full Code Here

Examples of com.hp.hpl.jena.tdb.store.bulkloader2.ProgressLogger.tick()

    monitor2.start();

    final RecordFactory recordFactory = new RecordFactory(LenNodeHash, SizeOfNodeId) ;
    Transform<Pair<byte[],Long>, Record> transformPair2Record = new Transform<Pair<byte[],Long>, Record>() {
        @Override public Record convert(Pair<byte[],Long> pair) {
            monitor2.tick();
            return recordFactory.create(pair.getLeft(), Bytes.packLong(pair.getRight()));
        }
    };

    int order = BPlusTreeParams.calcOrder(SystemTDB.BlockSize, recordFactory) ;
View Full Code Here

Examples of com.linkedin.databus.core.util.RateMonitor.tick()

            {
              seedingRate.resume();
              resumeSeedingRate = false;
            }
           
            seedingRate.tick();
           
            //LOG.info("Read record :" + record);           
            long start = System.nanoTime();
            long eventSize = sourceInfo.getFactory().createAndAppendEvent(windowSCN, timestamp, hdfsRecord,
                        _bootstrapEventBuffer, false, null);         
View Full Code Here

Examples of com.mojang.escape.gui.Sprite.tick()

  }

  public void tick() {
    for (int i = 0; i < sprites.size(); i++) {
      Sprite sprite = sprites.get(i);
      sprite.tick();
      if (sprite.removed) {
        sprites.remove(i--);
      }
    }
  }
View Full Code Here

Examples of com.mojang.ld22.entity.Entity.tick()

    for (int i = 0; i < entities.size(); i++) {
      Entity e = entities.get(i);
      int xto = e.x >> 4;
      int yto = e.y >> 4;

      e.tick();

      if (e.removed) {
        entities.remove(i--);
        removeEntity(xto, yto, e);
      } else {
View Full Code Here

Examples of com.netflix.hystrix.util.HystrixTimer.TimerListener.tick()

                            try {
                                return f.get(timeRemaining, TimeUnit.MILLISECONDS);
                            } catch (TimeoutException e) {
                                if (l != null) {
                                    // this perform the timeout logic on the Observable/Observer
                                    l.tick();
                                }
                            }
                        } else {
                            // this means it should have already timed out so do so if it is not completed
                            if (!f.isDone()) {
View Full Code Here

Examples of com.zeroqualitygames.spaceinvaders.entity.Entity.tick()

      }
 
     
      for (int i = 0; i < entities.size(); i++) {
        Entity e = entities.get(i);
        e.tick();
       
        if (reverse && e instanceof Alien) {
          ((Alien) e).reverse();
        }
       
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.