Last active
August 29, 2015 14:03
-
-
Save aspyker/bdb8c81ea3cb155a0fa3 to your computer and use it in GitHub Desktop.
First try at Rx+Ribbon2.0
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| actually look at https://gist.github.com/aspyker/517d4ceaccdeaa6087de |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
This is the most basic sample I could come up with. It seems like I have to do map or by the time something like toBlocking.first on original observable, the ByteBuf might be gone from Netty channel. Also, I realize this isn't such a great example if the caller here could be made async as well. Also, there isn't as much benefit as I'm not in any way parallelizing the requests.