Commits on Oct 1, 2013

1. BugFix: ConcurrencyStrategy.wrapCallable was not being used for react… …

   …ive event-loop threads.
   
   The Rx Scheduler now correctly has state transferred to it with ConcurrencyStrategy.wrapCallable.
   
   Note that if the Rx sequence ever migrates to another thread (such as using observeOn) it is up to the user to deal with this as Hystrix loses control of the flow at that point.
   
   This change does ensure though that the initial threads the callbacks are performed on has the expected thread context.
   
   The design of this code is not very elegant and uses a workaround similar to posting variables on a stack before a method uses them. I have used this approach because I do not want to add a 'wrapFunc2' method to the ConcurrencyStrategy as the use of Func2 is just an implementation detail internally and the users of the library should not have to replicate the effort for both Callable and Func2. Thus the internal code is a little odd but the public API is untouched.

   

   benjchristensen committed Oct 1, 2013
   Configuration menu

   • View commit details
   • Copy full SHA for 770d6a7
   • Browse repository at this point

   Copy the full SHA

   770d6a7 View commit details

   Browse the repository at this point in the history