question: move into a terminal state . call drain anytime after . 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
target: void function ( ) { terminated = true ; }