anchor.diff:  import 'dart:async';
   
   abstract class State extends Stream<String> {
  -  
  -  StreamController _controller;
  +
  +	StreamController<String> _controller;
     String _nextState;
     
  -  State([String nextState = null]): _nextState = nextState {        
  -    _controller = new StreamController<String>(
  -    onListen: _onListen,
  -    onPause: _onPause,
  -    onResume: _onResume,
  -    onCancel: _onCancel);
  +  State([String nextState = null]): _nextState = nextState {
  +	  _controller = new StreamController<String>(
  +			  onListen: _onListen,
  +			  onPause: _onPause,
  +			  onResume: _onResume,
  +			  onCancel: _onCancel);
     }
     
     StreamSubscription<String> listen(void onData(String line),
  
positive.code:                                      cancelOnError: cancelOnError);
    }
    
    _onListen(){
  	  print("Constructing");
      preload();
      create();
  
negative.code:                
    }
    
    void _onPause(){
  	  print("Pause");
    }
    
    void _onResume(){
  	  print("Resume");
    }
    
    void _onCancel(){
  	  print("Deconstructing");
    }
    
  