001/* 002 * Licensed to DuraSpace under one or more contributor license agreements. 003 * See the NOTICE file distributed with this work for additional information 004 * regarding copyright ownership. 005 * 006 * DuraSpace licenses this file to you under the Apache License, 007 * Version 2.0 (the "License"); you may not use this file except in 008 * compliance with the License. You may obtain a copy of the License at 009 * 010 * http://www.apache.org/licenses/LICENSE-2.0 011 * 012 * Unless required by applicable law or agreed to in writing, software 013 * distributed under the License is distributed on an "AS IS" BASIS, 014 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 015 * See the License for the specific language governing permissions and 016 * limitations under the License. 017 */ 018package org.fcrepo.kernel.modeshape.utils; 019 020import static java.util.Spliterator.IMMUTABLE; 021import static java.util.Spliterators.spliteratorUnknownSize; 022import static java.util.stream.StreamSupport.stream; 023 024import java.util.Iterator; 025import java.util.stream.Stream; 026 027/** 028 * @author acoburn 029 * @since February 10, 2016 030 */ 031public class StreamUtils { 032 033 /** 034 * Convert an Iterator to a Stream 035 * 036 * @param iterator the iterator 037 * @param <T> the type of the Stream 038 * @return the stream 039 */ 040 public static <T> Stream<T> iteratorToStream(final Iterator<T> iterator) { 041 return iteratorToStream(iterator, false); 042 } 043 044 /** 045 * Convert an Iterator to a Stream 046 * 047 * @param <T> the type of the Stream 048 * @param iterator the iterator 049 * @param parallel whether to parallelize the stream 050 * @return the stream 051 */ 052 public static <T> Stream<T> iteratorToStream(final Iterator<T> iterator, final Boolean parallel) { 053 return stream(spliteratorUnknownSize(iterator, IMMUTABLE), parallel); 054 } 055 private StreamUtils() { 056 // prevent instantiation 057 } 058} 059