private void assertSecondTestClass()

in timescaledb-connector/src/integration-test/java/com/epam/deltix/timebase/connector/service/timebase/TimebaseStreamReplicationServiceTest.java [295:314]

17 lines of code
1 McCabe index (conditional complexity)


    private void assertSecondTestClass(List<BaseTestClass> timeBaseEntities, List<BaseTestClass> timescaleEntities) {
        SecondTestClass timebaseSecondTestClass = (SecondTestClass) timeBaseEntities.stream()
                .filter(entity -> entity instanceof SecondTestClass)
                .findAny()
                .get();

        SecondTestClass timescaleSecondTestClass = (SecondTestClass) timescaleEntities.stream()
                .filter(entity -> entity instanceof SecondTestClass)
                .findAny()
                .get();

        assertThat(timebaseSecondTestClass.getByteaValue(), is(timescaleSecondTestClass.getByteaValue()));
        assertThat(timebaseSecondTestClass.getDecimal64Value(), is(timescaleSecondTestClass.getDecimal64Value()));
        assertThat(timebaseSecondTestClass.getStringValue(), is(timescaleSecondTestClass.getStringValue()));
        assertThat(timebaseSecondTestClass.getSymbol(), is(timescaleSecondTestClass.getSymbol()));

        assertThat(timebaseSecondTestClass.getEnumValue(), is(timescaleSecondTestClass.getEnumValue()));
        assertEquals(timebaseSecondTestClass.getSecondLongValue(), timescaleSecondTestClass.getSecondLongValue());
        assertThat(timebaseSecondTestClass.getSecondValue1(), is(timescaleSecondTestClass.getSecondValue1()));
    }