Package java.util

Examples of java.util.Observer


    }

    /* Update timeline for the duration of the plugin */
    repaintTimelineTimer.start();

    gui.addMoteHighlightObserver(moteHighlightObserver = new Observer() {
      public void update(Observable obs, Object obj) {
        if (!(obj instanceof Mote)) {
          return;
        }

View Full Code Here


          moteLEDs.isRedOn(),
          moteLEDs.isGreenOn(),
          moteLEDs.isYellowOn()
      );
      moteEvents.addLED(startupEv);
      Observer observer = new Observer() {
        public void update(Observable o, Object arg) {
          LEDEvent ev = new LEDEvent(
              simulation.getSimulationTime(),
              moteLEDs.isRedOn(),
              moteLEDs.isGreenOn(),
              moteLEDs.isYellowOn()
          );

          moteEvents.addLED(ev);
        }
      };

      moteLEDs.addObserver(observer);
      activeMoteObservers.add(new MoteObservation(mote, moteLEDs, observer));
    }

    /* Radio OnOff, RXTX, and channels */
    final Radio moteRadio = mote.getInterfaces().getRadio();
    if (moteRadio != null) {
      RadioChannelEvent startupChannel = new RadioChannelEvent(
          simulation.getSimulationTime(), moteRadio.getChannel(), moteRadio.isRadioOn());
      moteEvents.addRadioChannel(startupChannel);
      RadioHWEvent startupHW = new RadioHWEvent(
          simulation.getSimulationTime(), moteRadio.isRadioOn());
      moteEvents.addRadioHW(startupHW);
      RadioRXTXEvent startupRXTX = new RadioRXTXEvent(
          simulation.getSimulationTime(), RXTXRadioEvent.IDLE);
      moteEvents.addRadioRXTX(startupRXTX);
      Observer observer = new Observer() {
        int lastChannel = -1;
        public void update(Observable o, Object arg) {
          RadioEvent radioEv = moteRadio.getLastEvent();

          String details = null;
View Full Code Here

            Integer index = new Integer(i);

            // Replace or remove ParamObserver as needed.
            Object oldObs;
            if(parameter instanceof DeferredData) {
                Observer obs =
                    new ParamObserver(i, (DeferredData)parameter);
                oldObs = paramObservers.put(index, obs);
            } else {
                oldObs = paramObservers.remove(index);
            }
View Full Code Here

      public synchronized void deleteObserver(Observer o)
      {
         clearCollected();
         for (WeakReference<Observer> w : observer)
         {
            Observer tmp = w.get();
            if (tmp != null && tmp.equals(o))
            {
               observer.remove(o);
               break;
            }
View Full Code Here

         clearCollected();
         if (hasChanged())
         {
            for (WeakReference<Observer> w : observer)
            {
               Observer tmp = w.get();
               if (tmp != null)
               {
                  tmp.update(this, arg);
               }
            }
         }
      }
View Full Code Here

        if ( o == null )
        {
            o = new RequestObservable();
        }

        o.addObserver( new Observer()
        {
            public void update( Observable o, Object arg )
            {
                listener.requestAbandoned( AbstractAbandonableRequest.this );
            }
View Full Code Here

/* 293 */       Object parameter = parameters.get(i);
/* 294 */       Integer index = new Integer(i);
/*     */       Object oldObs;
/*     */       Object oldObs;
/* 298 */       if ((parameter instanceof DeferredData)) {
/* 299 */         Observer obs = new ParamObserver(i, (DeferredData)parameter);
/*     */
/* 301 */         oldObs = this.paramObservers.put(index, obs);
/*     */       } else {
/* 303 */         oldObs = this.paramObservers.remove(index);
/*     */       }
View Full Code Here

            Runtime.getRuntime().addShutdownHook( m_hook );
        }

        // If an Observer is present in the data object, then add it as an observer for
        //  m_observable
        Observer observer = (Observer)data.get( Observer.class.getName() );
        if( null != observer )
        {
            addObserver( observer );
        }
View Full Code Here

        throws ContextException
    {
        m_context = context;
        try
        {
            final Observer observer = (Observer)context.get( Observer.class.getName() );
            m_observable.addObserver( observer );
        }
        catch( final ContextException ce )
        {
            final String message = REZ.getString( "embeddor.notice.no-restart" );
View Full Code Here

        if ( o == null )
        {
            o = new RequestObservable();
        }

        o.addObserver( new Observer()
        {
            public void update( Observable o, Object arg )
            {
                listener.requestAbandoned( AbstractAbandonableRequest.this );
            }
View Full Code Here

TOP

Related Classes of java.util.Observer

Copyright © 2018 www.massapicom. 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.