@Test public void should_convert_liquibase() { LegacyEndpointConverter converter = LegacyEndpointConverters.liquibase(); assertThat(converter.canConvert("liquibase")).isTrue(); assertThat(converter.canConvert("foo")).isFalse(); Flux<DataBuffer> legacyInput = this.read("liquibase-legacy.json"); Flux<Object> converted = converter.convert(legacyInput).transform(this::unmarshal); Flux<Object> expected = this.read("liquibase-expected.json").transform(this::unmarshal); StepVerifier.create(Flux.zip(converted, expected)) .assertNext(t -> assertThat(t.getT1()).isEqualTo(t.getT2())) .verifyComplete(); }
public static LegacyEndpointConverter liquibase() { return new LegacyEndpointConverter(Endpoint.LIQUIBASE, convertUsing(RESPONSE_TYPE_LIST_MAP, RESPONSE_TYPE_MAP, LegacyEndpointConverters::convertLiquibase)); }
LegacyEndpointConverters { public static LegacyEndpointConverter liquibase() { return new LegacyEndpointConverter(Endpoint.LIQUIBASE, convertUsing(RESPONSE_TYPE_LIST_MAP, RESPONSE_TYPE_MAP, LegacyEndpointConverters::convertLiquibase)); } }
LegacyEndpointConverters { public static LegacyEndpointConverter liquibase() { return new LegacyEndpointConverter(Endpoint.LIQUIBASE, convertUsing(RESPONSE_TYPE_LIST_MAP, RESPONSE_TYPE_MAP, LegacyEndpointConverters::convertLiquibase)); } private  LegacyEndpointConverters(); }
LegacyEndpointConverters { public static LegacyEndpointConverter liquibase() { return new LegacyEndpointConverter(Endpoint.LIQUIBASE, convertUsing(RESPONSE_TYPE_LIST_MAP, RESPONSE_TYPE_MAP, LegacyEndpointConverters::convertLiquibase)); } private  LegacyEndpointConverters(); static LegacyEndpointConverter health(); static LegacyEndpointConverter env(); static LegacyEndpointConverter httptrace(); static LegacyEndpointConverter threaddump(); static LegacyEndpointConverter liquibase(); static LegacyEndpointConverter flyway(); static LegacyEndpointConverter info(); }
LegacyEndpointConverters { public static LegacyEndpointConverter liquibase() { return new LegacyEndpointConverter(Endpoint.LIQUIBASE, convertUsing(RESPONSE_TYPE_LIST_MAP, RESPONSE_TYPE_MAP, LegacyEndpointConverters::convertLiquibase)); } private  LegacyEndpointConverters(); static LegacyEndpointConverter health(); static LegacyEndpointConverter env(); static LegacyEndpointConverter httptrace(); static LegacyEndpointConverter threaddump(); static LegacyEndpointConverter liquibase(); static LegacyEndpointConverter flyway(); static LegacyEndpointConverter info();  }