HystrixObservableCollapser implements HystrixObservable<ResponseType> { static void reset() { RequestCollapserFactory.reset(); } protected  HystrixObservableCollapser(); protected  HystrixObservableCollapser(HystrixCollapserKey collapserKey); protected  HystrixObservableCollapser(Setter setter);   HystrixObservableCollapser(HystrixCollapserKey collapserKey, Scope scope, CollapserTimer timer, HystrixCollapserProperties.Setter propertiesBuilder, HystrixCollapserMetrics metrics); HystrixCollapserKey getCollapserKey(); Scope getScope(); HystrixCollapserMetrics getMetrics(); abstract RequestArgumentType getRequestArgument(); Observable<ResponseType> observe(); Observable<ResponseType> toObservable(); Observable<ResponseType> toObservable(Scheduler observeOn);  }
@Test public void stressTestRequestCollapser() throws Exception { for(int i = 0; i < 10; i++) { init(); testTwoRequests(); ctx.reset(); } }