@Test public void clearSinks() { pipeline.addSink(sink); pipeline.clearSinks(); source.sendTestMessage(); assertFalse(sink.received); }
public void clearSinks() { for (VehicleDataSink mSink : mSinks) { (mSink).stop(); } mSinks.clear(); }
DataPipeline implements SourceCallback { public void clearSinks() { for (VehicleDataSink mSink : mSinks) { (mSink).stop(); } mSinks.clear(); } }
DataPipeline implements SourceCallback { public void clearSinks() { for (VehicleDataSink mSink : mSinks) { (mSink).stop(); } mSinks.clear(); } DataPipeline();  DataPipeline(Operator operator); }
DataPipeline implements SourceCallback { public void clearSinks() { for (VehicleDataSink mSink : mSinks) { (mSink).stop(); } mSinks.clear(); } 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 clearSinks() { for (VehicleDataSink mSink : mSinks) { (mSink).stop(); } mSinks.clear(); } 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();  }