Skip to main content
aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
Diffstat (limited to 'plugins/org.eclipse.tm.tcf.core')
-rw-r--r--plugins/org.eclipse.tm.tcf.core/src/org/eclipse/tm/internal/tcf/services/local/ChannelProxy.java10
1 files changed, 4 insertions, 6 deletions
diff --git a/plugins/org.eclipse.tm.tcf.core/src/org/eclipse/tm/internal/tcf/services/local/ChannelProxy.java b/plugins/org.eclipse.tm.tcf.core/src/org/eclipse/tm/internal/tcf/services/local/ChannelProxy.java
index 9a760cef2..da46a156b 100644
--- a/plugins/org.eclipse.tm.tcf.core/src/org/eclipse/tm/internal/tcf/services/local/ChannelProxy.java
+++ b/plugins/org.eclipse.tm.tcf.core/src/org/eclipse/tm/internal/tcf/services/local/ChannelProxy.java
@@ -90,12 +90,11 @@ class ChannelProxy {
}
public void result(IToken token, byte[] data) {
- ch_x.sendResult(tokens_x.get(token), data);
- tokens_x.remove(token);
+ ch_x.sendResult(tokens_x.remove(token), data);
}
public void terminated(IToken token, Exception error) {
- tokens_x.remove(token);
+ ch_x.rejectCommand(tokens_x.remove(token));
}
};
@@ -106,12 +105,11 @@ class ChannelProxy {
}
public void result(IToken token, byte[] data) {
- ch_y.sendResult(tokens_y.get(token), data);
- tokens_y.remove(token);
+ ch_y.sendResult(tokens_y.remove(token), data);
}
public void terminated(IToken token, Exception error) {
- tokens_y.remove(token);
+ ch_y.rejectCommand(tokens_y.remove(token));
}
};

Back to the top