255                 if (completed) return;

   255                 if (completed) return;

   256                 completed = true;

   256                 completed = true;

   257                 subscribed = subscribedDone;

   257                 subscribed = subscribedDone;

   258             }

   258             }

   259             if (subscribed) {

   259             if (subscribed) {

   260                 delegate.onComplete();

   261                 delegate.onComplete();

   261             } else {

   262             } else {

   262                 debug.log(Level.DEBUG,

   263                 debug.log(Level.DEBUG,

   263                           "Subscriber not yet subscribed: stored completed=true");

   264                           "Subscriber not yet subscribed: stored completed=true");

   264             }

   265             }