还是有更好的方法来做到这一点我失踪了?我想创建一个基于供应商(通常是无限制)的流,但是当供应商返回null时,流将终止.我自己做了这个,但是完成一个简单的概念似乎是相当多的工作.
public class NullTerminatedStreamFactory { static int characteristics = Spliterator.ORDERED | Spliterator.disTINCT; public static<T> Stream<T> makeNullTerminatedStream(supplier<T> supplier) { return StreamSupport.stream(new NullTerminatedSpliteratorFromsupplier<>(supplier,Long.MAX_VALUE,characteristics),false); } static class NullTerminatedSpliteratorFromsupplier<T> extends Spliterators.AbstractSpliterator<T> { public NullTerminatedSpliteratorFromsupplier(supplier<T> supplier,long est,int additionalcharacteristics) { super(est,additionalcharacteristics); this.supplier = supplier; } public supplier<T> supplier; @Override public boolean tryAdvance(Consumer<? super T> action) { T next = supplier.get(); if (next != null) { action.accept(next); return true; } return false; } } }
为了记录,我正在使用它,基本上从BlockingQueue创建一个流:
NullTerminatedStreamFactory.makeNullTerminatedStream(() -> { try { BlockingQueue<Message> queue = getBlockingQueue(); return queue.poll(1,TimeUnit.SECONDS); } catch (Exception e) { log.error("Exception while trying to get message from queue",e); } return null; });
解决方法
您已经找到了完美有效的手工实现.
如评论中所述,Java 9似乎添加了一个takeWhile(Predicate)
方法.在此之前,您可以使用实现类似takeWhile()的第三方库:
jOOλ
jOOλ有limitWhile(),它做同样的事情:
Seq.generate(supplier).limitWhile(Objects::nonNull);
(免责声明,我为jOOλ之后的公司工作)
Javaslang
Javaslang实现了自己的Stream类,它受到Scala集合的启发,因此带有Widget()
Stream.gen(supplier).takeWhile(Objects::nonNull);
功能Java
Functional Java还配有自己的Stream实现,那有一个takeWhile()方法:
Stream.fromFunction(i -> supplier.get()).takeWhile(o -> o != null);
原文地址:https://www.jb51.cc/java/124206.html
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。