ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/jsr166/jsr166/src/main/java/util/concurrent/Flow.java
(Generate patch)

Comparing jsr166/src/main/java/util/concurrent/Flow.java (file contents):
Revision 1.6 by jsr166, Thu Jan 15 17:31:03 2015 UTC vs.
Revision 1.7 by jsr166, Thu Jan 15 17:37:21 2015 UTC

# Line 255 | Line 255 | public final class Flow {
255       * @param consumer the function applied to each onNext item
256       * @return a CompletableFuture that is completed normally
257       * when the publisher signals onComplete, and exceptionally
258 <     * upon any error.
258 >     * upon any error
259       * @throws NullPointerException if publisher or consumer are null
260       * @throws IllegalArgumentException if requestSize not positive
261       */
# Line 280 | Line 280 | public final class Flow {
280       * @param consumer the function applied to each onNext item
281       * @return a CompletableFuture that is completed normally
282       * when the publisher signals onComplete, and exceptionally
283 <     * upon any error.
283 >     * upon any error
284       * @throws NullPointerException if publisher or consumer are null
285       */
286      public static <T> CompletableFuture<Void> consume(
# Line 325 | Line 325 | public final class Flow {
325       * @param streamFunction the operation on elements
326       * @return a CompletableFuture that is completed normally with the
327       * result of the given function as result when the publisher signals
328 <     * onComplete, and exceptionally upon any error.
328 >     * onComplete, and exceptionally upon any error
329       * @throws NullPointerException if publisher or function are null
330       * @throws IllegalArgumentException if requestSize not positive
331       */
# Line 352 | Line 352 | public final class Flow {
352       * @param streamFunction the operation on elements
353       * @return a CompletableFuture that is completed normally with the
354       * result of the given function as result when the publisher signals
355 <     * onComplete, and exceptionally upon any error.
355 >     * onComplete, and exceptionally upon any error
356       * @throws NullPointerException if publisher or function are null
357       */
358      public static <T,R> CompletableFuture<R> stream(

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines