Corrected handling of exceptions

[mono.git] / mcs / class / System.Threading.Tasks.Dataflow / System.Threading.Tasks.Dataflow / MessageBox.cs

diff --git a/mcs/class/System.Threading.Tasks.Dataflow/System.Threading.Tasks.Dataflow/MessageBox.cs b/mcs/class/System.Threading.Tasks.Dataflow/System.Threading.Tasks.Dataflow/MessageBox.cs
index d83abbe3cfb9a4903094480ad0a1e8e2982d1c52..fd6b7572ada054704b1e75c4c2d6ed9769e038d6 100644 (file)
--- a/mcs/class/System.Threading.Tasks.Dataflow/System.Threading.Tasks.Dataflow/MessageBox.cs
+++ b/mcs/class/System.Threading.Tasks.Dataflow/System.Threading.Tasks.Dataflow/MessageBox.cs
@@ -85,14 +85,18 @@ namespace System.Threading.Tasks.Dataflow
                {
                        // Make message queue complete
                        MessageQueue.CompleteAdding ();
+                       OutgoingQueueComplete ();
                        VerifyCompleteness ();
                }
 
-               void VerifyCompleteness ()
+               protected virtual void OutgoingQueueComplete ()
+               {
+               }
+
+               protected  virtual void VerifyCompleteness ()
                {
                        if (MessageQueue.IsCompleted && externalCompleteTester ())
                                compHelper.Complete ();
                }
        }
-}
-
+}
\ No newline at end of file