Commit 200fe919 authored by Marc Gravell's avatar Marc Gravell

log unaccepted results via MessageFaulted

parent ddb2c1ac
...@@ -588,7 +588,14 @@ internal bool ComputeResult(PhysicalConnection connection, RawResult result) ...@@ -588,7 +588,14 @@ internal bool ComputeResult(PhysicalConnection connection, RawResult result)
try try
{ {
if (box != null && box.IsFaulted) return false; // already failed (timeout, etc) if (box != null && box.IsFaulted) return false; // already failed (timeout, etc)
return resultProcessor == null || resultProcessor.SetResult(connection, this, result); if (resultProcessor == null) return true;
var accepted = resultProcessor.SetResult(connection, this, result);
if (!accepted)
{
connection?.BridgeCouldBeNull?.Multiplexer?.OnMessageFaulted(this, null);
}
return accepted;
} }
catch (Exception ex) catch (Exception ex)
{ {
...@@ -610,7 +617,7 @@ internal void SetException(Exception exception) ...@@ -610,7 +617,7 @@ internal void SetException(Exception exception)
resultBox?.SetException(exception); resultBox?.SetException(exception);
} }
internal void SetEnqueued()=> performance?.SetEnqueued(); internal void SetEnqueued() => performance?.SetEnqueued();
internal void SetRequestSent() internal void SetRequestSent()
{ {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment