We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent ffc89d0 commit 59d4264Copy full SHA for 59d4264
1 file changed
src/main/java/org/numenta/nupic/network/Layer.java
@@ -846,10 +846,6 @@ public void run() {
846
847
Layer.this.compute((T)intArray);
848
849
- if(Thread.currentThread().isInterrupted()) {
850
- notifyError(new RuntimeException("Unknown Exception during compute"));
851
- }
852
-
853
// Notify all downstream observers that the stream is closed
854
if(!sensor.hasNext()) {
855
notifyComplete();
@@ -1207,6 +1203,11 @@ void notifyComplete() {
1207
1203
publisher.onCompleted();
1208
1204
}
1209
1205
1206
+ /**
+ * Called internally to propagate the specified {@link Exception}
+ * up the network hierarchy
+ * @param e the exception to notify users of
1210
+ */
1211
void notifyError(Exception e) {
1212
for(Observer<Inference> o : subscribers) {
1213
o.onError(e);
0 commit comments