354                     debug.log("Downstream subscription cancelled by %s", pending);

   354                     debug.log("Downstream subscription cancelled by %s", pending);

   355                 // The connection should be closed, as some data may

   355                 // The connection should be closed, as some data may

   356                 // be left over in the stream.

   356                 // be left over in the stream.

   357                 try {

   357                 try {

   358                     setRetryOnError(false);

   358                     setRetryOnError(false);

   359                     onReadError(new IOException("subscription cancelled"));

   360                     onReadError(new IOException("subscription cancelled"));

   360                     unsubscribe(pending);

   361                     unsubscribe(pending);

   361                 } finally {

   362                 } finally {

   362                     Http1Exchange<?> exchg = owner;

   363                     Http1Exchange<?> exchg = owner;

   363                     stop();

   364                     stop();