Reverting task changes.

rabbitmq · Feb 7, 2023 · 8669618 · 8669618
1 parent 457cedd
commit 8669618
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/projects/RabbitMQ.Client/client/impl/Connection.cs b/projects/RabbitMQ.Client/client/impl/Connection.cs
@@ -79,7 +79,7 @@ public Connection(ConnectionConfig config, IFrameHandler frameHandler)
                 ["connection_name"] = ClientProvidedName
             };
 
-            _mainLoopTask = Task.Factory.StartNew(MainLoop, TaskCreationOptions.LongRunning).Unwrap();
+            _mainLoopTask = Task.Run(MainLoop);
             try
             {
                 Open();

diff --git a/projects/RabbitMQ.Client/client/impl/SocketFrameHandler.cs b/projects/RabbitMQ.Client/client/impl/SocketFrameHandler.cs
@@ -148,7 +148,7 @@ public SocketFrameHandler(AmqpTcpEndpoint endpoint,
             _pipeReader = PipeReader.Create(netstream);
 
             WriteTimeout = writeTimeout;
-            _writerTask = Task.Factory.StartNew(WriteLoop, TaskCreationOptions.LongRunning).Unwrap();
+            _writerTask = Task.Run(WriteLoop);
         }
 
         public AmqpTcpEndpoint Endpoint
-Original file line number
+Diff line change
@@ Expand Up @@
                     ["connection_name"] = ClientProvidedName
                 };
-                _mainLoopTask = Task.Factory.StartNew(MainLoop, TaskCreationOptions.LongRunning).Unwrap();
+                _mainLoopTask = Task.Run(MainLoop);
                 try
                 {
                     Open();
@@ Expand Down @@