private void scheduleDirect ( CoreScheduler scheduler , final CouchbaseResponse response , final Subject < CouchbaseResponse , CouchbaseResponse > observable ) { scheduler . scheduleDirect ( new Action0 ( ) { @ Override public void call ( ) { completeResponse ( response , observable ) ; } } ) ; }
Optimized version of dispatching onto the core scheduler through direct scheduling .