class Upstream {

  public void cancel() {
    Subscription currentSubscription =
        (Subscription) SUBSCRIPTION.getAndSet(this, FlowSupport.NOOP_SUBSCRIPTION);
    if (currentSubscription != null) {
      currentSubscription.cancel();
    }
  }

  public  Upstream();

}