class ListDataStream implements DataStream<T> {

    @SafeVarargs
    public static <T> ListDataStream<T> create(T... ts) {
        ListDataStream<T> stream = new ListDataStream<>();
        for (T t : ts) {
            stream.append(t);
        }
        return stream;
    }

}