Invoked after handing off the elements produced from one input element to the downstream subscribers to determine whether to end stream processing at this point; in that case the upstream subscription is canceled.