Clear our active flag before passing requestFailed() onto the subscriber
so that things go smoothly if they decide in requestFailed() to call unsubscribe() in the course of their normal shuttings down. git-svn-id: svn+ssh://src.earth.threerings.net/narya/trunk@2920 542714f4-19e9-0310-aa3c-eee0fc999fb1
This commit is contained in:
@@ -1,5 +1,5 @@
|
|||||||
//
|
//
|
||||||
// $Id: SafeSubscriber.java,v 1.4 2003/12/15 17:12:11 mdb Exp $
|
// $Id: SafeSubscriber.java,v 1.5 2003/12/17 00:15:08 mdb Exp $
|
||||||
|
|
||||||
package com.threerings.presents.util;
|
package com.threerings.presents.util;
|
||||||
|
|
||||||
@@ -187,10 +187,10 @@ public class SafeSubscriber
|
|||||||
|
|
||||||
// if we're active, let our subscriber know that the shit hit the fan
|
// if we're active, let our subscriber know that the shit hit the fan
|
||||||
if (_active) {
|
if (_active) {
|
||||||
_subscriber.requestFailed(oid, cause);
|
// deactivate ourselves as we never got our object (and thus
|
||||||
// and deactivate ourselves as we never got our object (and
|
// the real subscriber need not call unsubscribe())
|
||||||
// thus the real subscriber need not call unsubscribe())
|
|
||||||
_active = false;
|
_active = false;
|
||||||
|
_subscriber.requestFailed(oid, cause);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user