Skip to content
This repository has been archived by the owner on Oct 23, 2024. It is now read-only.

Improve scheduling and backpressure of Mesos response stream #13

Closed
cruhland opened this issue Nov 7, 2015 · 2 comments
Closed

Improve scheduling and backpressure of Mesos response stream #13

cruhland opened this issue Nov 7, 2015 · 2 comments
Milestone
0.2.0

Comments

@cruhland
Copy link
Contributor

cruhland commented Nov 7, 2015

In MesosSchedulerClient.openEventStream(), there are some comments regarding backpressure and custom schedulers. Investigate how to improve the code so that the comments can be removed.
@BenWhitehead BenWhitehead modified the milestone: 0.1.0 Nov 19, 2015
@BenWhitehead BenWhitehead removed this from the 0.1.0 milestone May 5, 2016
@zonybob
Copy link

zonybob commented Jul 20, 2017

Thought I'd comment on this rather than creating a new issue.
I am getting the dreaded MissingBackpressureException with my rx-mesos based scheduler.
Where is the right place to chain .onBackpressureBuffer(...) ?
It seems like trying to chain it to the unicastEvents is not going to work since it uses buffer(timespan) which explicitly does not support backpressure.

@zonybob zonybob mentioned this issue Jul 22, 2017
Merged
@BenWhitehead BenWhitehead added this to the 0.2.0 milestone Jul 28, 2017
BenWhitehead added a commit that referenced this issue Aug 4, 2017
@BenWhitehead
Merge pull request #81 from zonybob/gh-13-backpressure
25959f8 
Enhance Backpressure Support in Mesos Response Stream
@BenWhitehead
Copy link
Contributor

Fixed in #81

Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Assignees
No one assigned
Labels
None yet
Projects
None yet
Milestone
0.2.0
Development

No branches or pull requests
3 participants
@BenWhitehead @cruhland @zonybob