Decouple Operations from Composable/Stream/Promise
Decouple Batching Operations from Composable/Stream/Promise attempting to fix #208 and rework PR #177.
Add a few utilities to render a Composable tree
Work In Progress, not all tests green yet
fix a few tests, improve debug utils for Composable
fix a few tests, improve debug utils for Composable, Complete Stream functional migration
fix new Reactor creation
fix dispatcher creation and fix some doc
Add FlatMap operation, Optimize recursive flush, add abstraction for operation pipes such as Composables to implement flush and addOperation
Fix promises ctr
Fix Promise Tests and improve OpUtils
Fix Perf Tests
Fix TCP test, rename ForwardOperation to ConnectOperation, Add debugging output for FilterOperation, fix issue in ReactorBuilder
Merge remote-tracking branch 'remotes/origin/master' into improve-stream-promise
Remove interface, rename operation to Action
Change Composable Spec to accept observable,
add Streams.on
first and last can accept explicit batchSize
Fix Recursive dispatching, tail recurse any notify within context
Add a new dispatcher type "ActorDispatcher"
Fix Recursive Dispatching by lazy executing any notify in context. Context is defined per BaseDispatcher with its unique ClassLoader assigned to the consumer thread. In others terms, ring buffer and event loop now implement tail recursion. Synchronous Dispatcher is still blocking on notify. ThreadPoolExecutorDispatcher needs rework. Performances are nearly on par with the previous version and the new design solves dead lock issues. The stack now remains constant (Lazy execution at the dispatcher root). ActorDispatcher is a new Dispatcher type that allows concurrent recursive notification by assigning a unique Dispatcher per Event Key. Combined with EventLoop pool from environment, we act like multi-actor systems.
Comment ThreadPool test and minor import fix
fix ThreadPool dispatching
Rename BaseDispatcher to SingleThreadDispatcher and promote BaseLifecycleDispatcher as the root Dispatcher
Increase the sample length back