moved all sync-over-async functionality to it's own namespace (#901)

Author: mhowlett

examples/AvroBlogExamples/Program.cs

@@ -16,6 +16,7 @@
 
 using Avro.Generic;
 using Confluent.Kafka;
+using Confluent.Kafka.SyncOverAsync;
 using Confluent.SchemaRegistry.Serdes;
 using Confluent.SchemaRegistry;
 using System;

examples/AvroGeneric/Program.cs

@@ -16,6 +16,7 @@
 
 using Avro;
 using Avro.Generic;
+using Confluent.Kafka.SyncOverAsync;
 using Confluent.SchemaRegistry.Serdes;
 using Confluent.SchemaRegistry;
 using System;

examples/AvroSpecific/Program.cs

@@ -18,6 +18,7 @@
 using System.Collections.Generic;
 using System.Threading;
 using System.Threading.Tasks;
+using Confluent.Kafka.SyncOverAsync;
 using Confluent.SchemaRegistry;
 using Confluent.SchemaRegistry.Serdes;
 

src/Confluent.Kafka/SyncOverAsyncDeserializer.cs

@@ -1,6 +1,6 @@
 using System;
 
-namespace Confluent.Kafka
+namespace Confluent.Kafka.SyncOverAsync
 {
     /// <summary>
     ///     An adapter that allows an async deserializer
@@ -86,7 +86,7 @@ public static class SyncOverAsyncDeserializerExtensionMethods
         /// <summary>
         ///     Create a sync deserializer by wrapping an async
         ///     one. For more information on the potential
-        ///     pitfalls in doing this, refer to <see cref="Confluent.Kafka.SyncOverAsyncDeserializer{T}" />.
+        ///     pitfalls in doing this, refer to <see cref="Confluent.Kafka.SyncOverAsync.SyncOverAsyncDeserializer{T}" />.
         /// </summary>
         public static IDeserializer<T> AsSyncOverAsync<T>(this IAsyncDeserializer<T> asyncDeserializer)
             => new SyncOverAsyncDeserializer<T>(asyncDeserializer);

src/Confluent.Kafka/SyncOverAsyncSerializer.cs

@@ -1,6 +1,6 @@
 using System;
 
-namespace Confluent.Kafka
+namespace Confluent.Kafka.SyncOverAsync
 {
     /// <summary>
     ///     An adapter that allows an async serializer
@@ -76,7 +76,6 @@ public byte[] Serialize(T data, SerializationContext context)
                 .GetResult();
     }
 
-
     /// <summary>
     ///     Extension methods related to SyncOverAsyncSerializer.
     /// </summary>
@@ -85,7 +84,7 @@ public static class SyncOverAsyncSerializerExtensionMethods
         /// <summary>
         ///     Create a sync serializer by wrapping an async
         ///     one. For more information on the potential
-        ///     pitfalls in doing this, refer to <see cref="Confluent.Kafka.SyncOverAsyncSerializer{T}" />.
+        ///     pitfalls in doing this, refer to <see cref="Confluent.Kafka.SyncOverAsync.SyncOverAsyncSerializer{T}" />.
         /// </summary>
         public static ISerializer<T> AsSyncOverAsync<T>(this IAsyncSerializer<T> asyncSerializer)
             => new SyncOverAsyncSerializer<T>(asyncSerializer);

test/Confluent.Kafka.IntegrationTests/Serdes.cs

@@ -17,6 +17,7 @@
 using System.Threading;
 using System.Threading.Tasks;
 using Confluent.Kafka;
+using Confluent.Kafka.SyncOverAsync;
 
 namespace Confluent.Kafka.IntegrationTests
 {

test/Confluent.SchemaRegistry.Serdes.IntegrationTests/Tests/AvroAndRegular.cs

@@ -17,6 +17,7 @@
 using Confluent.Kafka;
 using Confluent.SchemaRegistry;
 using Confluent.SchemaRegistry.Serdes;
+using Confluent.Kafka.SyncOverAsync;
 using Confluent.Kafka.Examples.AvroSpecific;
 using System;
 using System.Collections.Generic;

test/Confluent.SchemaRegistry.Serdes.IntegrationTests/Tests/ConsumeIncompatibleTypes.cs

@@ -19,6 +19,7 @@
 using Confluent.Kafka;
 using Confluent.SchemaRegistry;
 using Confluent.SchemaRegistry.Serdes;
+using Confluent.Kafka.SyncOverAsync;
 using Confluent.Kafka.Examples.AvroSpecific;
 using Xunit;
 

test/Confluent.SchemaRegistry.Serdes.IntegrationTests/Tests/ConsumePartitionEOF.cs

@@ -18,6 +18,7 @@
 using System.Collections.Generic;
 using System.Linq;
 using Confluent.Kafka;
+using Confluent.Kafka.SyncOverAsync;
 using Confluent.SchemaRegistry;
 using Confluent.SchemaRegistry.Serdes;
 using Confluent.Kafka.Examples.AvroSpecific;

test/Confluent.SchemaRegistry.Serdes.IntegrationTests/Tests/PrimitiveTypes.cs

@@ -18,6 +18,7 @@
 using System.Collections.Generic;
 using System.Threading;
 using Confluent.Kafka;
+using Confluent.Kafka.SyncOverAsync;
 using Confluent.SchemaRegistry;
 using Confluent.SchemaRegistry.Serdes;
 using Xunit;