30
30
31
31
import java .util .Set ;
32
32
import java .util .concurrent .atomic .AtomicReference ;
33
+ import java .util .function .BiFunction ;
33
34
import java .util .function .Function ;
34
35
import java .util .stream .Collectors ;
35
36
import java .util .stream .Stream ;
@@ -169,12 +170,12 @@ public void testDeprecationLogging() {
169
170
}
170
171
171
172
public void testUpdateWithUnknownAndSettings () {
172
- runUpdateWithUnknownAndInvalidSettingTest (builder -> builder ::persistentSettings , MetaData ::persistentSettings );
173
- runUpdateWithUnknownAndInvalidSettingTest (builder -> builder ::transientSettings , MetaData ::transientSettings );
173
+ runUpdateWithUnknownAndInvalidSettingTest (MetaData . Builder ::persistentSettings , MetaData ::persistentSettings );
174
+ runUpdateWithUnknownAndInvalidSettingTest (MetaData . Builder ::transientSettings , MetaData ::transientSettings );
174
175
}
175
176
176
177
private void runUpdateWithUnknownAndInvalidSettingTest (
177
- final Function <MetaData .Builder , Function < Settings , MetaData .Builder >> function ,
178
+ final BiFunction <MetaData .Builder , Settings , MetaData .Builder > metaDataSettingsBuilder ,
178
179
final Function <MetaData , Settings > settingsToTest ) {
179
180
final Setting <String > dynamicSetting = Setting .simpleString ("dynamic.setting" , Property .Dynamic , Property .NodeScope );
180
181
final Setting <String > invalidSetting = Setting .simpleString (
@@ -196,7 +197,7 @@ private void runUpdateWithUnknownAndInvalidSettingTest(
196
197
final ClusterState clusterState =
197
198
ClusterState
198
199
.builder (new ClusterName ("cluster" ))
199
- .metaData (function .apply (MetaData .builder ()). apply ( settings ).build ())
200
+ .metaData (metaDataSettingsBuilder .apply (MetaData .builder (), settings ).build ())
200
201
.build ();
201
202
final Settings toApply = Settings .builder ().put ("dynamic.setting" , "value" ).build ();
202
203
final boolean applyTransient = randomBoolean ();
0 commit comments