@Nonnull
    public static <T> Sink<T> list(@Nonnull String listName) {
        return fromProcessor("listSink(" + listName + ')', writeListP(listName));
    }
@Test
    public void when_writeToMultipleStagesToSingleSink_then_allItemsInSink() {
        // Given
        String secondSourceName = randomName();
        List<Integer> input = sequence(itemCount);
        addToSrcList(input);
        hz().getList(secondSourceName).addAll(input);
        BatchStage<Entry<Object, Object>> firstSource = p.readFrom(Sources.list(srcName));
        BatchStage<Entry<Object, Object>> secondSource = p.readFrom(Sources.list(secondSourceName));

        // When
        p.writeTo(Sinks.list(sinkName), firstSource, secondSource);

        // Then
        execute();
        assertEquals(itemCount * 2, sinkList.size());
    }