SuccessChanges

Summary

  1. Add pictures to the spec to illustrate shapes (commit: 86dc262) (details)
  2. Restructuration (commit: 6054777) (details)
  3. Make org.eclipse.microprofile.reactive.streams.CompletionSubscriber#of (commit: ba52b39) (details)
  4. Add the PeekStageVerification to the test suite (commit: 8b99270) (details)
  5. Fix issue in an example from the stream spec (commit: f366c57) (details)
  6. Introduce a flatMapPublisher method (commit: 9356d86) (details)
  7. Fix issue with Java 8 (commit: 475c339) (details)
  8. Remove the non use stage (commit: 642086d) (details)
  9. Fix typos in the peek stage javadoc and signature (commit: 65d6984) (details)
  10. Define a `distinct` stage as discussed in #51. (commit: 4b2706c) (details)
  11. fix build break (commit: 45baa7e) (details)
  12. Add a viariant of the `collect` method (commit: 084253b) (details)
  13. Add a section in the spec about the similarities and differences with (commit: d1f9b22) (details)
  14. Revert generic type changes. (commit: 1fa34a7) (details)
  15. Rename CompletionBuilder to CompletionRunner (commit: ab82d70) (details)
  16. Fix build after the merge of the `collect` stage (commit: a02e08a) (details)
  17. Define onError, onTerminate and onComplete (commit: 3a85a60) (details)
  18. Define onError, onTerminate and onComplete (commit: a2116fc) (details)
  19. Extend onTerminate stage TCK (commit: 83de29e) (details)
Commit 86dc262c0cb6a12650ce0a3c7182c8592687d903 by Clement Escoffier
Add pictures to the spec to illustrate shapes
Signed-off-by: Clement Escoffier <clement.escoffier@gmail.com>
(commit: 86dc262)
The file was modifiedstreams/spec/src/main/asciidoc/architecture.asciidoc (diff)
The file was addedstreams/spec/src/main/asciidoc/images/graph.png
The file was modified.gitignore (diff)
The file was addedstreams/spec/src/main/asciidoc/images/publisher.png
The file was addedstreams/spec/src/main/asciidoc/images/picture-sources.odg
The file was addedstreams/spec/src/main/asciidoc/images/shapes.png
The file was addedstreams/spec/src/main/asciidoc/images/processor.png
The file was addedstreams/spec/src/main/asciidoc/images/subscriber.png
Commit 6054777d1f1d78cf3318f0ebffd5577c30d714b8 by Clement Escoffier
Restructuration
Signed-off-by: Clement Escoffier <clement.escoffier@gmail.com>
(commit: 6054777)
The file was modifiedstreams/spec/src/main/asciidoc/architecture.asciidoc (diff)
The file was modifiedstreams/spec/src/main/asciidoc/microprofile-reactive-streams-spec.asciidoc (diff)
The file was addedstreams/spec/src/main/asciidoc/spi.asciidoc
Commit ba52b3978dd24db6aff215a6ba81aaa0b02ae8da by Clement Escoffier
Make org.eclipse.microprofile.reactive.streams.CompletionSubscriber#of
public
Fixes #44
Signed-off-by: Clement Escoffier <clement.escoffier@gmail.com>
(commit: ba52b39)
The file was modifiedstreams/api/src/main/java/org/eclipse/microprofile/reactive/streams/CompletionSubscriber.java (diff)
Commit 8b99270a30b68591f72c1c51d4d21cb7b00a88ef by Clement Escoffier
Add the PeekStageVerification to the test suite
Fixes #46.
Signed-off-by: Clement Escoffier <clement.escoffier@gmail.com>
(commit: 8b99270)
The file was modifiedstreams/tck/src/main/java/org/eclipse/microprofile/reactive/streams/tck/ReactiveStreamsTck.java (diff)
Commit f366c57f682837d4c4fc915c8d0c247f5d5840f3 by Clement Escoffier
Fix issue in an example from the stream spec
The existing code was not correct.
Signed-off-by: Clement Escoffier <clement.escoffier@gmail.com>
(commit: f366c57)
The file was modifiedstreams/spec/src/main/asciidoc/architecture.asciidoc (diff)
Commit 9356d860607a672b76bc3c4240db90569e05b6ea by Clement Escoffier
Introduce a flatMapPublisher method
This new stage is an adaptation of the flatMap stage but the mapper
function returns a Publisher instead of a PublisherBuilder. The tests
are derived from the flatMap verification test suites
Signed-off-by: Clement Escoffier <clement.escoffier@gmail.com>
(commit: 9356d86)
The file was modifiedstreams/api/src/main/java/org/eclipse/microprofile/reactive/streams/spi/Stage.java (diff)
The file was addedstreams/tck/src/main/java/org/eclipse/microprofile/reactive/streams/tck/FlatMapPublisherStageVerification.java
The file was modifiedstreams/api/src/main/java/org/eclipse/microprofile/reactive/streams/ProcessorBuilder.java (diff)
The file was modifiedstreams/tck/src/main/java/org/eclipse/microprofile/reactive/streams/tck/ReactiveStreamsTck.java (diff)
The file was modifiedstreams/api/src/main/java/org/eclipse/microprofile/reactive/streams/PublisherBuilder.java (diff)
Commit 475c33955ee0d457fa95990aa031542f7ab58931 by Clement Escoffier
Fix issue with Java 8
But was working with Java 9...
Signed-off-by: Clement Escoffier <clement.escoffier@gmail.com>
(commit: 475c339)
The file was modifiedstreams/tck/src/main/java/org/eclipse/microprofile/reactive/streams/tck/FlatMapPublisherStageVerification.java (diff)
Commit 642086db1d3cc621887b30c9f4660ad6c54b4a95 by Clement Escoffier
Remove the non use stage
Signed-off-by: Clement Escoffier <clement.escoffier@gmail.com>
(commit: 642086d)
The file was modifiedstreams/api/src/main/java/org/eclipse/microprofile/reactive/streams/spi/Stage.java (diff)
Commit 65d69840b0ca9f5b5aee31f8a1ee0bcb14103c76 by Clement Escoffier
Fix typos in the peek stage javadoc and signature
Signed-off-by: Clement Escoffier <clement.escoffier@gmail.com>
(commit: 65d6984)
The file was modifiedstreams/api/src/main/java/org/eclipse/microprofile/reactive/streams/ProcessorBuilder.java (diff)
The file was modifiedstreams/api/src/main/java/org/eclipse/microprofile/reactive/streams/PublisherBuilder.java (diff)
Commit 4b2706c4c5c1a8ebc45590f951d151735459e65b by Clement Escoffier
Define a `distinct` stage as discussed in #51.
Signed-off-by: Clement Escoffier <clement.escoffier@gmail.com>
(commit: 4b2706c)
The file was modifiedstreams/api/src/main/java/org/eclipse/microprofile/reactive/streams/ProcessorBuilder.java (diff)
The file was modifiedstreams/api/src/main/java/org/eclipse/microprofile/reactive/streams/PublisherBuilder.java (diff)
The file was addedstreams/tck/src/main/java/org/eclipse/microprofile/reactive/streams/tck/DistinctStageVerification.java
The file was modifiedstreams/tck/src/main/java/org/eclipse/microprofile/reactive/streams/tck/ReactiveStreamsTck.java (diff)
The file was modifiedstreams/api/src/main/java/org/eclipse/microprofile/reactive/streams/spi/Stage.java (diff)
Commit 45baa7ed13b05e22b32ef4bee62558028a6abcf3 by Emily Jiang
fix build break
Signed-off-by: Emily Jiang <emijiang@uk.ibm.com>
(commit: 45baa7e)
The file was modifiedmessaging/api/pom.xml (diff)
Commit 084253b0f6ec812f9a4fda2b0dc3d811e0966bcc by Clement Escoffier
Add a viariant of the `collect` method
As discussed in #51, define a variant of the collect method accepting a
supplier and a biconsumer. Because of Reactive Streams, combiner is not
used and so not part of the signature
Signed-off-by: Clement Escoffier <clement.escoffier@gmail.com>
(commit: 084253b)
The file was modifiedstreams/api/src/main/java/org/eclipse/microprofile/reactive/streams/ProcessorBuilder.java (diff)
The file was modifiedstreams/tck/src/main/java/org/eclipse/microprofile/reactive/streams/tck/CollectStageVerification.java (diff)
The file was modifiedstreams/api/src/main/java/org/eclipse/microprofile/reactive/streams/PublisherBuilder.java (diff)
Commit d1f9b22194e9ca08ee30dfd7e74f7d73dc0a004c by Clement Escoffier
Add a section in the spec about the similarities and differences with
the Java Stream API
Related to #51.
Signed-off-by: Clement Escoffier <clement.escoffier@gmail.com>
(commit: d1f9b22)
The file was addedstreams/spec/src/main/asciidoc/java-streams.asciidoc
The file was modifiedstreams/spec/src/main/asciidoc/microprofile-reactive-streams-operators-spec.asciidoc (diff)
Commit 1fa34a795b296adcd7a4910b1aa07dc838a74596 by Clement Escoffier
Revert generic type changes.
Signed-off-by: Clement Escoffier <clement.escoffier@gmail.com>
(commit: 1fa34a7)
The file was modifiedstreams/api/src/main/java/org/eclipse/microprofile/reactive/streams/ProcessorBuilder.java (diff)
Commit ab82d706dccf86597215e9670b0cde57d3107a23 by Clement Escoffier
Rename CompletionBuilder to CompletionRunner
This change has been discussed during the MP Reactive call (July 3rd)
and is related to #16.
In addition to the code change, the spec has been updated.
Signed-off-by: Clement Escoffier <clement.escoffier@gmail.com>
(commit: ab82d70)
The file was removedstreams/api/src/main/java/org/eclipse/microprofile/reactive/streams/CompletionBuilder.java
The file was modifiedstreams/spec/src/main/asciidoc/architecture.asciidoc (diff)
The file was modifiedstreams/tck/src/main/java/org/eclipse/microprofile/reactive/streams/tck/FilterStageVerification.java (diff)
The file was modifiedstreams/api/src/main/java/org/eclipse/microprofile/reactive/streams/PublisherBuilder.java (diff)
The file was addedstreams/api/src/main/java/org/eclipse/microprofile/reactive/streams/CompletionRunner.java
The file was modifiedstreams/api/src/main/java/org/eclipse/microprofile/reactive/streams/package-info.java (diff)
Commit a02e08a83449a0a08c4ef33b20c5045f1ddbb75c by Clement Escoffier
Fix build after the merge of the `collect` stage
Signed-off-by: Clement Escoffier <clement.escoffier@gmail.com>
#56 was developped before the renaming from CompletionBuilder to
CompletionRunner (#58). As a consequence, the compilation fails. This
commit fixes it.
(commit: a02e08a)
The file was modifiedstreams/api/src/main/java/org/eclipse/microprofile/reactive/streams/PublisherBuilder.java (diff)
Commit 3a85a6015c4ebb3588ad3fe1f0420b80fef49468 by Clement Escoffier
Define onError, onTerminate and onComplete
Add the 3 stages called at 3 different moments of the stream lifecycle.
onError is called when the stream conveys a failure. onComplete is
called when the stream completes. onTerminate is called in both cases.
onComplete is already the equivalent of the BaseStream.onClose method.
The TCK for the 3 stages is merged in a single file as these stages
behaves almost indentically. The only difference is the "when" the
passed functions are called.
Signed-off-by: Clement Escoffier <clement.escoffier@gmail.com>
(commit: 3a85a60)
The file was modifiedstreams/spec/src/main/asciidoc/java-streams.asciidoc (diff)
The file was modifiedstreams/api/src/main/java/org/eclipse/microprofile/reactive/streams/ProcessorBuilder.java (diff)
The file was addedstreams/tck/src/main/java/org/eclipse/microprofile/reactive/streams/tck/OnStagesVerification.java
The file was modifiedstreams/api/src/main/java/org/eclipse/microprofile/reactive/streams/spi/Stage.java (diff)
The file was modifiedstreams/tck/src/main/java/org/eclipse/microprofile/reactive/streams/tck/ReactiveStreamsTck.java (diff)
The file was modifiedstreams/api/src/main/java/org/eclipse/microprofile/reactive/streams/PublisherBuilder.java (diff)
Commit a2116fc6b39ec306cabeb60d87f3f0663e7e5e32 by Clement Escoffier
Define onError, onTerminate and onComplete
Add the 3 stages called at 3 different moments of the stream lifecycle.
onError is called when the stream conveys a failure. onComplete is
called when the stream completes. onTerminate is called in both cases.
onComplete is already the equivalent of the BaseStream.onClose method.
The TCK for the 3 stages is merged in a single file as these stages
behaves almost indentically. The only difference is the "when" the
passed functions are called.
Signed-off-by: Clement Escoffier <clement.escoffier@gmail.com>
(commit: a2116fc)
The file was modifiedstreams/api/src/main/java/org/eclipse/microprofile/reactive/streams/PublisherBuilder.java (diff)
The file was modifiedstreams/spec/src/main/asciidoc/java-streams.asciidoc (diff)
The file was modifiedstreams/api/src/main/java/org/eclipse/microprofile/reactive/streams/spi/Stage.java (diff)
The file was modifiedstreams/api/src/main/java/org/eclipse/microprofile/reactive/streams/ProcessorBuilder.java (diff)
The file was addedstreams/tck/src/main/java/org/eclipse/microprofile/reactive/streams/tck/OnStagesVerification.java
The file was modifiedstreams/tck/src/main/java/org/eclipse/microprofile/reactive/streams/tck/ReactiveStreamsTck.java (diff)
Commit 83de29e4f41a8dc09b3dc1101ba33d7d37496662 by Clement Escoffier
Extend onTerminate stage TCK
Add a test checking that the onTerminate stage is called when the stream
is cancelled downtstream
Signed-off-by: Clement Escoffier <clement.escoffier@gmail.com>
(commit: 83de29e)
The file was modifiedstreams/api/src/main/java/org/eclipse/microprofile/reactive/streams/PublisherBuilder.java (diff)
The file was modifiedstreams/tck/src/main/java/org/eclipse/microprofile/reactive/streams/tck/OnStagesVerification.java (diff)
The file was modifiedstreams/api/src/main/java/org/eclipse/microprofile/reactive/streams/ProcessorBuilder.java (diff)
The file was modifiedstreams/api/src/main/java/org/eclipse/microprofile/reactive/streams/spi/Stage.java (diff)