@@ -0,0 +1,1333 @@
+/**%0A * Copyright (c) 2016 European Organisation for Nuclear Research (CERN), All Rights Reserved.%0A */%0A%0Apackage cern.streaming.pool.core.service.util;%0A%0Aimport java.util.Objects;%0Aimport java.util.function.Supplier;%0A%0Aimport cern.streaming.pool.core.service.ReactiveStream;%0Aimport cern.streaming.pool.core.service.StreamCreator;%0Aimport cern.streaming.pool.core.service.StreamId;%0Aimport cern.streaming.pool.core.service.impl.IdentifiedStreamCreator;%0A%0Apublic final class StreamCreators %7B%0A%0A    private StreamCreators() %7B%0A        /* Only static methods */%0A    %7D%0A%0A    public static %3CT%3E OngoingCreatorCreation%3CT%3E create(StreamCreator%3CT%3E creator) %7B%0A        return new OngoingCreatorCreation%3C%3E(creator);%0A    %7D%0A%0A    public static %3CT%3E OngoingCreatorCreation%3CT%3E create(Supplier%3CReactiveStream%3CT%3E%3E supplier) %7B%0A        return new OngoingCreatorCreation%3CT%3E(discovery -%3E supplier.get());%0A    %7D%0A%0A    public static class OngoingCreatorCreation%3CT%3E %7B%0A        private final StreamCreator%3CT%3E streamCreator;%0A%0A        public OngoingCreatorCreation(StreamCreator%3CT%3E streamCreator) %7B%0A            this.streamCreator = Objects.requireNonNull(streamCreator, %22streamCreator must not be null.%22);%0A        %7D%0A%0A        public IdentifiedStreamCreator%3CT%3E as(StreamId%3CT%3E streamId) %7B%0A            return IdentifiedStreamCreator.of(streamId, streamCreator);%0A        %7D%0A    %7D%0A%0A%7D%0A

Revert "cleanup"