@Test public void addSource() { pipeline.addSource(source); assertThat(source.callback, notNullValue()); }
public VehicleDataSource addSource(VehicleDataSource source) { source.setCallback(this); mSources.add(source); if(isActive()) { source.onPipelineActivated(); } else { source.onPipelineDeactivated(); } return source; }
DataPipeline implements SourceCallback { public VehicleDataSource addSource(VehicleDataSource source) { source.setCallback(this); mSources.add(source); if(isActive()) { source.onPipelineActivated(); } else { source.onPipelineDeactivated(); } return source; } }
DataPipeline implements SourceCallback { public VehicleDataSource addSource(VehicleDataSource source) { source.setCallback(this); mSources.add(source); if(isActive()) { source.onPipelineActivated(); } else { source.onPipelineDeactivated(); } return source; } DataPipeline();  DataPipeline(Operator operator); }
DataPipeline implements SourceCallback { public VehicleDataSource addSource(VehicleDataSource source) { source.setCallback(this); mSources.add(source); if(isActive()) { source.onPipelineActivated(); } else { source.onPipelineDeactivated(); } return source; } DataPipeline();  DataPipeline(Operator operator); @Override void receive(VehicleMessage message); VehicleDataSink addSink(VehicleDataSink sink); void removeSink(VehicleDataSink sink); VehicleDataSource addSource(VehicleDataSource source); void removeSource(VehicleDataSource source); List<VehicleDataSource> getSources(); List<VehicleDataSink> getSinks(); void stop(); void clearSources(); void clearSinks(); KeyedMessage get(MessageKey key); int getMessageCount(); boolean isActive(); boolean isActive(VehicleDataSource skipSource); @Override void sourceDisconnected(VehicleDataSource source); @Override void sourceConnected(VehicleDataSource source); @Override String toString(); }
DataPipeline implements SourceCallback { public VehicleDataSource addSource(VehicleDataSource source) { source.setCallback(this); mSources.add(source); if(isActive()) { source.onPipelineActivated(); } else { source.onPipelineDeactivated(); } return source; } DataPipeline();  DataPipeline(Operator operator); @Override void receive(VehicleMessage message); VehicleDataSink addSink(VehicleDataSink sink); void removeSink(VehicleDataSink sink); VehicleDataSource addSource(VehicleDataSource source); void removeSource(VehicleDataSource source); List<VehicleDataSource> getSources(); List<VehicleDataSink> getSinks(); void stop(); void clearSources(); void clearSinks(); KeyedMessage get(MessageKey key); int getMessageCount(); boolean isActive(); boolean isActive(VehicleDataSource skipSource); @Override void sourceDisconnected(VehicleDataSource source); @Override void sourceConnected(VehicleDataSource source); @Override String toString();  }