@Test
    void testBothValid() throws IOException {
        commonTranslationTestHelper.setup();

        final List<ProcessorResult> results = commonTranslationTestHelper.processAll();

        assertThat(results).hasSize(N4);
        for (final ProcessorResult result : results) {
            assertThat(result.getWritten())
                    .as(result.toString())
                    .isGreaterThan(0);
            assertThat(result.getRead())
                    .as(result.toString())
                    .isLessThanOrEqualTo(result.getWritten());
            assertThat(result.getMarkerCount(Severity.SEVERITIES))
                    .as(result.toString())
                    .isZero();
        }

        final Path inputDir = StroomPipelineTestFileUtil.getTestResourcesDir().resolve(DIR);
        final Path outputDir = StroomPipelineTestFileUtil.getTestOutputDir().resolve(DIR);

        for (final Entry<Long, Meta> entry : metaService.getMetaMap().entrySet()) {
            final long streamId = entry.getKey();
            final Meta meta = entry.getValue();
            if (StreamTypeNames.EVENTS.equals(meta.getTypeName())) {
                final byte[] data = streamStore.getFileData().get(streamId).get(meta.getTypeName());

                // Write the actual XML out.
                final OutputStream os = StroomPipelineTestFileUtil.getOutputStream(outputDir,
                        "TestTranslationTask.out");
                os.write(data);
                os.flush();
                os.close();

                ComparisonHelper.compareFiles(inputDir.resolve("TestTranslationTask.out"),
                        outputDir.resolve("TestTranslationTask.out"));
            }
        }

        // Make sure 26 records were written.
        assertThat(results.get(N3).getWritten())
                .isEqualTo(26);
    }
Tests Task with a valid resource and feed.

@throws IOException Could be thrown.
stroom-app/src/test/java/stroom/pipeline/task/TestTranslationTask.java