@Test public void writeMultipleNamesForSameChannel() throws Exception { ReadExpressionTester exp = new ReadExpressionTester(mapOf(latestValueOf(channels("foo", "foo(2.0)")))); ReadRecipe recipe = exp.getReadRecipe(); LocalDataSource dataSource = new LocalDataSource(); dataSource.connectRead(recipe); assertThat(dataSource.getChannels().size(), equalTo(1)); dataSource.disconnectRead(recipe); dataSource.close(); }
@Override public void connectRead(ReadRecipe readRecipe) { super.connectRead(readRecipe); for (ChannelReadRecipe channelReadRecipe : readRecipe.getChannelReadRecipes()) { initialize(channelReadRecipe.getChannelName()); } }
LocalDataSource extends DataSource { @Override public void connectRead(ReadRecipe readRecipe) { super.connectRead(readRecipe); for (ChannelReadRecipe channelReadRecipe : readRecipe.getChannelReadRecipes()) { initialize(channelReadRecipe.getChannelName()); } } }
LocalDataSource extends DataSource { @Override public void connectRead(ReadRecipe readRecipe) { super.connectRead(readRecipe); for (ChannelReadRecipe channelReadRecipe : readRecipe.getChannelReadRecipes()) { initialize(channelReadRecipe.getChannelName()); } } LocalDataSource(); @Deprecated  LocalDataSource(boolean zeroInitialization); }
LocalDataSource extends DataSource { @Override public void connectRead(ReadRecipe readRecipe) { super.connectRead(readRecipe); for (ChannelReadRecipe channelReadRecipe : readRecipe.getChannelReadRecipes()) { initialize(channelReadRecipe.getChannelName()); } } LocalDataSource(); @Deprecated  LocalDataSource(boolean zeroInitialization); @Override void connectRead(ReadRecipe readRecipe); @Override void connectWrite(WriteRecipe writeRecipe); }
LocalDataSource extends DataSource { @Override public void connectRead(ReadRecipe readRecipe) { super.connectRead(readRecipe); for (ChannelReadRecipe channelReadRecipe : readRecipe.getChannelReadRecipes()) { initialize(channelReadRecipe.getChannelName()); } } LocalDataSource(); @Deprecated  LocalDataSource(boolean zeroInitialization); @Override void connectRead(ReadRecipe readRecipe); @Override void connectWrite(WriteRecipe writeRecipe);  }