Simplified code with Observable.observeOn().

Netflix / suro

Netflix's distributed Data Pipeline

Apache License 2.0

794 stars 170 forks source link

Closed allenxwang closed 9 years ago

cloudbees-pull-request-builder commented 9 years ago

suro-pull-requests #150 FAILURE Looks like there's a problem with this pull request

cloudbees-pull-request-builder commented 9 years ago

suro-pull-requests #151 FAILURE Looks like there's a problem with this pull request

cloudbees-pull-request-builder commented 9 years ago

suro-pull-requests #152 SUCCESS This pull request looks good