public static Flux<Object> readAll(Reader reader) throws IOException {
        return readAll(DEFAULT_OBJECT_MAPPER, reader, DEFAULT_TYPE_REFERENCE);
    }
@Test
    void readAll_fromEmptySource() throws IOException {
        final Path inputTempFilePath = createTempFile();

        final List<Object> outputValues = FileSerde.readAll(Files.newBufferedReader(inputTempFilePath)).collectList().block();
        assertThat(outputValues, empty());
    }