formatting

Signed-off-by: Gabriele Santomaggio <[email protected]>

Author: Gsantomaggio

Tests/SystemTests.cs

@@ -110,7 +110,7 @@ public async void Create_Stream_With_Max_Length_Maximum_Value()
             var stream = Guid.NewGuid().ToString();
             var config = new StreamSystemConfig();
             var system = await StreamSystem.Create(config);
-            var spec = new StreamSpec(stream) {MaxLengthBytes = ulong.MaxValue};
+            var spec = new StreamSpec(stream) { MaxLengthBytes = ulong.MaxValue };
             await system.CreateStream(spec);
             Assert.Equal(ulong.MaxValue.ToString(), spec.Args["max-length-bytes"]);
             await system.DeleteStream(stream);
@@ -144,7 +144,7 @@ public async void StreamStatus()
         [Fact]
         public async void CreateSystemThrowsWhenVirtualHostFailureAccess()
         {
-            var config = new StreamSystemConfig {VirtualHost = "DOES_NOT_EXIST"};
+            var config = new StreamSystemConfig { VirtualHost = "DOES_NOT_EXIST" };
             await Assert.ThrowsAsync<VirtualHostAccessFailureException>(
                 async () => { await StreamSystem.Create(config); }
             );
@@ -153,7 +153,7 @@ await Assert.ThrowsAsync<VirtualHostAccessFailureException>(
         [Fact]
         public async void CreateSystemThrowsWhenAuthenticationAccess()
         {
-            var config = new StreamSystemConfig {UserName = "user_does_not_exist"};
+            var config = new StreamSystemConfig { UserName = "user_does_not_exist" };
             await Assert.ThrowsAsync<AuthenticationFailureException>(
                 async () => { await StreamSystem.Create(config); }
             );
@@ -185,10 +185,10 @@ public async void CreateExistStreamPreconditionFailShouldRaiseExceptions()
             var stream = Guid.NewGuid().ToString();
             var config = new StreamSystemConfig();
             var system = await StreamSystem.Create(config);
-            await system.CreateStream(new StreamSpec(stream) {MaxLengthBytes = 20,});
+            await system.CreateStream(new StreamSpec(stream) { MaxLengthBytes = 20, });
 
             await Assert.ThrowsAsync<CreateStreamException>(
-                async () => { await system.CreateStream(new StreamSpec(stream) {MaxLengthBytes = 10000,}); }
+                async () => { await system.CreateStream(new StreamSpec(stream) { MaxLengthBytes = 10000, }); }
             );
             await system.DeleteStream(stream);
             await system.Close();
@@ -250,13 +250,12 @@ public async void ValidateSalsExternalConfiguration()
         {
             // the user can set the SALs configuration externally
             // this test validates that the configuration is supported by the server
-            var config = new StreamSystemConfig() {AuthMechanism = AuthMechanism.External};
+            var config = new StreamSystemConfig() { AuthMechanism = AuthMechanism.External };
             await Assert.ThrowsAsync<AuthMechanismNotSupportedException>(
                 async () => { await StreamSystem.Create(config); }
             );
         }
 
-
         [Fact]
         public async void CloseProducerConsumerAfterForceCloseShouldNotRaiseError()
         {
@@ -270,10 +269,10 @@ public async void CloseProducerConsumerAfterForceCloseShouldNotRaiseError()
             var system = await StreamSystem.Create(config);
             await system.CreateStream(new StreamSpec(stream));
             var producer =
-                await system.CreateRawProducer(new RawProducerConfig(stream) {ClientProvidedName = clientProvidedName});
+                await system.CreateRawProducer(new RawProducerConfig(stream) { ClientProvidedName = clientProvidedName });
             SystemUtils.Wait();
             var consumer = await system.CreateRawConsumer(
-                new RawConsumerConfig(stream) {ClientProvidedName = clientProvidedName});
+                new RawConsumerConfig(stream) { ClientProvidedName = clientProvidedName });
             SystemUtils.Wait();
 
             // Here we have to wait the management stats refresh time before killing the connections.
@@ -297,7 +296,7 @@ public async void SetHeartBeat()
         {
             // Just test the heartbeat setting
             // TODO find a smarter way to test the heartbeat disconnection
-            var config = new StreamSystemConfig() {Heartbeat = TimeSpan.FromMinutes(1),};
+            var config = new StreamSystemConfig() { Heartbeat = TimeSpan.FromMinutes(1), };
             var system = await StreamSystem.Create(config);
             var stream = Guid.NewGuid().ToString();
             await system.CreateStream(new StreamSpec(stream));