@Test public void removeSink() { pipeline.addSink(sink); TestSink anotherSink = new TestSink(); pipeline.addSink(anotherSink); pipeline.removeSink(sink); source.sendTestMessage(); assertFalse(sink.received); }
public void removeSink(VehicleDataSink sink) { if(sink != null) { mSinks.remove(sink); sink.stop(); } }
DataPipeline implements SourceCallback { public void removeSink(VehicleDataSink sink) { if(sink != null) { mSinks.remove(sink); sink.stop(); } } }
DataPipeline implements SourceCallback { public void removeSink(VehicleDataSink sink) { if(sink != null) { mSinks.remove(sink); sink.stop(); } } DataPipeline();  DataPipeline(Operator operator); }
DataPipeline implements SourceCallback { public void removeSink(VehicleDataSink sink) { if(sink != null) { mSinks.remove(sink); sink.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 removeSink(VehicleDataSink sink) { if(sink != null) { mSinks.remove(sink); sink.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();  }