private void assertFirstTestClass()

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

17 lines of code
1 McCabe index (conditional complexity)


    private void assertFirstTestClass(List<BaseTestClass> timeBaseEntities, List<BaseTestClass> timescaleEntities) {
        FirstTestClass timebaseFirstTestClass = (FirstTestClass) timeBaseEntities.stream()
                .filter(entity -> entity instanceof FirstTestClass)
                .findAny()
                .get();

        FirstTestClass timescaleFirstTestClass = (FirstTestClass) timescaleEntities.stream()
                .filter(entity -> entity instanceof FirstTestClass)
                .findAny()
                .get();

        assertThat(timebaseFirstTestClass.getByteaValue(), is(timescaleFirstTestClass.getByteaValue()));
        assertThat(timebaseFirstTestClass.getDecimal64Value(), is(timescaleFirstTestClass.getDecimal64Value()));
        assertThat(timebaseFirstTestClass.getStringValue(), is(timescaleFirstTestClass.getStringValue()));
        assertThat(timebaseFirstTestClass.getSymbol(), is(timescaleFirstTestClass.getSymbol()));

        assertEquals(timebaseFirstTestClass.getCharValue(), timescaleFirstTestClass.getCharValue());
        assertEquals(timebaseFirstTestClass.getIntValue(), timescaleFirstTestClass.getIntValue());
        assertEquals(timebaseFirstTestClass.getLongValue(), timescaleFirstTestClass.getLongValue());
    }