iconara / ione

98%

master: 99%

LAST BUILD ON BRANCH streams

branch: streams

CHANGE BRANCH

x

Reset

• streams
• 1.2.0.pre4
• acceptor-host-and-port
• after-factory
• byte-buffer-getbyte
• byte-buffer-index
• deprecate-future-value
• destructive-future-combinators
• fix-jruby-test-issues
• fix-warnings
• future_improvements
• handle_badf_in_select
• http_server
• improve-base-connection-locks
• io-reactor-drain
• master
• optimize-resolved-combine
• optimize_future_combinators
• optimized_scheduler
• restartable_reactor
• running-while-stopping
• ssl_support
• ssl_support_on_1.2
• stack-safe-after
• stack-safe-reduce
• synchronized_close
• thread-pooling
• travis-test
• travis_debug
• try-complete-promise
• unblock-once
• uncaught-error-handler
• v1.0.0
• v1.1.0
• v1.1.0.pre0
• v1.1.1
• v1.1.2
• v1.1.3
• v1.1.4
• v1.1.5
• v1.1.x
• v1.2.0.pre0
• v1.2.0.pre1
• v1.2.0.pre2
• v1.2.0.pre3
• v1.2.0.pre4
• v1.2.0.pre6
• v1.2.0.pre7
• v1.2.0.pre8
• v1.2.1
• v1.2.2
• v1.2.3
• v1.2.4
• v1.2.x
• v1.3.0.pre0
• v1.3.0.pre1
• v1.3.0.pre2

Change things around to get closer to the reactive streams spec

* Stream#subscribe now takes a Subscriber
* PushStream is renamed Source and has a #<< for publishing
* #subscribe and #unsubscribe are encapsulated in Publisher
* The private #deliver method of Stream has been encapsulated in a class called Processor, which is both a Publisher and a Subscriber, and rename it #call
* The combinators have been rewritten to be Sources