class Upstream {

  public void request(long n) {
    Subscription currentSubscription = subscription;
    if (currentSubscription != null) {
      currentSubscription.request(n);
    }
  }

  public  Upstream();

}