void function ( Exception arg0 ) { if ( ! isTerminated ( ) ) { responseSubject . onError ( arg0 ) ; } else { throw new IllegalStateException ( "srini_string" , arg0 ) ; } }
when set any client thread blocking on get will immediately be unblocked and receive the exception . concode_field_sep R argument concode_elem_sep PublishSubject<T> responseSubject concode_elem_sep AtomicBoolean valueSet concode_field_sep void call concode_elem_sep void setExceptionIfResponseNotReceived concode_elem_sep Exception setExceptionIfResponseNotReceived concode_elem_sep boolean isTerminated concode_elem_sep R getArgument concode_elem_sep void setResponse concode_elem_sep void setComplete concode_elem_sep void emitResponse