Reverting task changes.

stebet · lukebakken · commit 8669618331f1 · 2023-02-07T13:47:25.000-08:00
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 number	Diff line change
`@@ -79,7 +79,7 @@ public Connection(ConnectionConfig config, IFrameHandler frameHandler)`
`79`	`79`	`["connection_name"] = ClientProvidedName`
`80`	`80`	`};`
`81`	`81`
`82`		`- _mainLoopTask = Task.Factory.StartNew(MainLoop, TaskCreationOptions.LongRunning).Unwrap();`
	`82`	`+ _mainLoopTask = Task.Run(MainLoop);`
`83`	`83`	`try`
`84`	`84`	`{`
`85`	`85`	`Open();`
Original file line number	Diff line number	Diff line change
`@@ -148,7 +148,7 @@ public SocketFrameHandler(AmqpTcpEndpoint endpoint,`
`148`	`148`	`_pipeReader = PipeReader.Create(netstream);`
`149`	`149`
`150`	`150`	`WriteTimeout = writeTimeout;`
`151`		`- _writerTask = Task.Factory.StartNew(WriteLoop, TaskCreationOptions.LongRunning).Unwrap();`
	`151`	`+ _writerTask = Task.Run(WriteLoop);`
`152`	`152`	`}`
`153`	`153`
`154`	`154`	`public AmqpTcpEndpoint Endpoint`