protected void publishResponse ( final CouchbaseResponse response , final Subject < CouchbaseResponse , CouchbaseResponse > observable ) { if ( response . status ( ) != ResponseStatus . RETRY && observable != null ) { if ( moveResponseOut ) { Scheduler scheduler = env ( ) . scheduler ( ) ; if ( scheduler instanceof CoreScheduler ) { scheduleDirect ( ( CoreScheduler ) scheduler , response , observable ) ; } else { scheduleWorker ( scheduler , response , observable ) ; } } else { completeResponse ( response , observable ) ; } } else { responseBuffer . publishEvent ( ResponseHandler . RESPONSE_TRANSLATOR , response , observable ) ; } }
Publishes a response with the attached observable .