@Test public void removeSource() { pipeline.addSource(source); TestSource anotherSource = new TestSource(); pipeline.addSource(anotherSource); pipeline.removeSource(source); source.sendTestMessage(); assertFalse(sink.received); }
public void removeSource(VehicleDataSource source) { if(source != null) { mSources.remove(source); source.stop(); } }
DataPipeline implements SourceCallback { public void removeSource(VehicleDataSource source) { if(source != null) { mSources.remove(source); source.stop(); } } }
DataPipeline implements SourceCallback { public void removeSource(VehicleDataSource source) { if(source != null) { mSources.remove(source); source.stop(); } } DataPipeline();  DataPipeline(Operator operator); }
DataPipeline implements SourceCallback { public void removeSource(VehicleDataSource source) { if(source != null) { mSources.remove(source); source.stop(); } } 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 void removeSource(VehicleDataSource source) { if(source != null) { mSources.remove(source); source.stop(); } } 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();  }