private void scheduleWorker ( Scheduler scheduler , final CouchbaseResponse response , final Subject < CouchbaseResponse , CouchbaseResponse > observable ) { final Scheduler . Worker worker = scheduler . createWorker ( ) ; worker . schedule ( new Action0 ( ) { @ Override public void call ( ) { completeResponse ( response , observable ) ; worker . unsubscribe ( ) ; } } ) ; }
Dispatches the response on a generic scheduler through creating a worker .