@Nonnull
    public static <T> Sink<T> noop() {
        return fromProcessor("noop", preferLocalParallelismOne(noopP()));
    }
@Test
    public void noop() {
        // Given
        populateList(srcList);

        // When
        Sink<Object> sink = Sinks.noop();

        // Then
        p.readFrom(Sources.list(srcName)).writeTo(sink);
        execute();
        // works without error
    }