move into a terminal state with an exception . call drain anytime after . serialized access is expected with respect to element emission . concode_field_sep Throwable exception concode_elem_sep BackpressureQueueCallback actual concode_elem_sep long requestedCount concode_elem_sep AtomicLongFieldUpdater<BackpressureDrainManager> REQUESTED_COUNT concode_elem_sep boolean emitting concode_elem_sep boolean terminated concode_field_sep void request concode_elem_sep boolean isTerminated concode_elem_sep Object poll concode_elem_sep void complete concode_elem_sep void terminateAndDrain concode_elem_sep void terminateAndDrain concode_elem_sep void drain concode_elem_sep Object peek concode_elem_sep boolean accept
void function ( Throwable arg0 ) { if ( ! terminated ) { exception = arg0 ; terminated = true ; } }