jdk/src/share/classes/java/util/stream/IntPipeline.java
changeset 19220 d3d40ccb544e
parent 18528 9b02581cf079
child 19593 ce0cd954351c
equal deleted inserted replaced
19219:0d4231d25a29 19220:d3d40ccb544e
   148                                            boolean isParallel) {
   148                                            boolean isParallel) {
   149         return new StreamSpliterators.IntWrappingSpliterator<>(ph, supplier, isParallel);
   149         return new StreamSpliterators.IntWrappingSpliterator<>(ph, supplier, isParallel);
   150     }
   150     }
   151 
   151 
   152     @Override
   152     @Override
       
   153     @SuppressWarnings("unchecked")
   153     final Spliterator.OfInt lazySpliterator(Supplier<? extends Spliterator<Integer>> supplier) {
   154     final Spliterator.OfInt lazySpliterator(Supplier<? extends Spliterator<Integer>> supplier) {
   154         return new StreamSpliterators.DelegatingSpliterator.OfInt((Supplier<Spliterator.OfInt>) supplier);
   155         return new StreamSpliterators.DelegatingSpliterator.OfInt((Supplier<Spliterator.OfInt>) supplier);
   155     }
   156     }
   156 
   157 
   157     @Override
   158     @Override
   188                                                      StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
   189                                                      StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
   189             @Override
   190             @Override
   190             Sink<Integer> opWrapSink(int flags, Sink<Long> sink) {
   191             Sink<Integer> opWrapSink(int flags, Sink<Long> sink) {
   191                 return new Sink.ChainedInt(sink) {
   192                 return new Sink.ChainedInt(sink) {
   192                     @Override
   193                     @Override
       
   194                     @SuppressWarnings("unchecked")
   193                     public void accept(int t) {
   195                     public void accept(int t) {
   194                         downstream.accept((long) t);
   196                         downstream.accept((long) t);
   195                     }
   197                     }
   196                 };
   198                 };
   197             }
   199             }
   204                                                        StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
   206                                                        StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
   205             @Override
   207             @Override
   206             Sink<Integer> opWrapSink(int flags, Sink<Double> sink) {
   208             Sink<Integer> opWrapSink(int flags, Sink<Double> sink) {
   207                 return new Sink.ChainedInt(sink) {
   209                 return new Sink.ChainedInt(sink) {
   208                     @Override
   210                     @Override
       
   211                     @SuppressWarnings("unchecked")
   209                     public void accept(int t) {
   212                     public void accept(int t) {
   210                         downstream.accept((double) t);
   213                         downstream.accept((double) t);
   211                     }
   214                     }
   212                 };
   215                 };
   213             }
   216             }
   243                                                              StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
   246                                                              StreamOpFlag.NOT_SORTED | StreamOpFlag.NOT_DISTINCT) {
   244             @Override
   247             @Override
   245             Sink<Integer> opWrapSink(int flags, Sink<U> sink) {
   248             Sink<Integer> opWrapSink(int flags, Sink<U> sink) {
   246                 return new Sink.ChainedInt(sink) {
   249                 return new Sink.ChainedInt(sink) {
   247                     @Override
   250                     @Override
       
   251                     @SuppressWarnings("unchecked")
   248                     public void accept(int t) {
   252                     public void accept(int t) {
   249                         downstream.accept(mapper.apply(t));
   253                         downstream.accept(mapper.apply(t));
   250                     }
   254                     }
   251                 };
   255                 };
   252             }
   256             }