Changes

Add pictures to the spec to illustrate shapes
Signed-off-by: Clement Escoffier <clement.escoffier@gmail.com>
 (commit: 86dc262)

Restructuration
Signed-off-by: Clement Escoffier <clement.escoffier@gmail.com>
 (commit: 6054777)

Make org.eclipse.microprofile.reactive.streams.CompletionSubscriber#of
public
Fixes #44
Signed-off-by: Clement Escoffier <clement.escoffier@gmail.com>
 (commit: ba52b39)

Add the PeekStageVerification to the test suite
Fixes #46.
Signed-off-by: Clement Escoffier <clement.escoffier@gmail.com>
 (commit: 8b99270)

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)

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)

Fix issue with Java 8
But was working with Java 9...
Signed-off-by: Clement Escoffier <clement.escoffier@gmail.com>
 (commit: 475c339)

Remove the non use stage
Signed-off-by: Clement Escoffier <clement.escoffier@gmail.com>
 (commit: 642086d)

Fix typos in the peek stage javadoc and signature
Signed-off-by: Clement Escoffier <clement.escoffier@gmail.com>
 (commit: 65d6984)

Define a `distinct` stage as discussed in #51.
Signed-off-by: Clement Escoffier <clement.escoffier@gmail.com>
 (commit: 4b2706c)

fix build break
Signed-off-by: Emily Jiang <emijiang@uk.ibm.com>
 (commit: 45baa7e)

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)

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)

Revert generic type changes.
Signed-off-by: Clement Escoffier <clement.escoffier@gmail.com>
 (commit: 1fa34a7)

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)

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)

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)

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)

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)