Remove Event type constraint for Dispatcher and Router - Reactor now handle headerSelector on new consumers (previously in ConsumerFilteringEventRouter). Router classes have been renamed to reflect the new type (*EventRouter -> *Router)
First cut at the Reactive Streams implementation. Several changes have been applied to the reactor.core.composable package. Major internal refactoring have updated the behavior of Composable to almost completely fulfil the Reactor Stream contract.
A Composable now doesn't rely on an Observable anymore to schedule its events nor use Event envelope type. A simple Dispatcher is required to schedule plain data processing.
An Action is a first-class citizen for user implementation to create asynchronous services. All its callback methods run asynchronously over its bound dispatcher.
Merge Master
Down to 32 failing tests...
And it compiles :) Now fixing tests
Fix StreamUtils
merge master
Fix a compile error
Update spec to new API
Propagate keepAlive
Add Promise support to StreamUtils
Improve logging output (at least for the stabilization phase)
Pass some TCK
Down from 94 failing tests to 36
Down to 30 failed core tests and up to 66% TCK green
Down to 14 failed core tests and up to 11/36 TCK ok
rearrange methods
All the TCK passes !
Moved buffering logic over Subscription, cascade requests and replay from stored position ForEachAction
it also passes with RingBufferDispatcher
A new range of tests fixed - TCK still passing
18 tests and counting. Consume is now properly requesting the number of elements according to its batchSize
2!!!!
Passing tests !! Now time for refining and porting other modules...