Adds more write overloads to Utf8Json

src/Elasticsearch.Net/Serialization/DiagnosticsSerializerProxy.cs

@@ -32,12 +32,16 @@ public SerializerRegistrationInformation(Type type, string purpose)
 		public override string ToString() => _stringRepresentation;
 	}
 
+	//TODO this no longer needs to be IInternalSerializerWithFormatter
+	// Previous we checked that the serializer we are wrapping implements the interface and if so set the formatter
+	// However its totally fine for formatter to be null. `IJsonFormatter` solves this better.
 	/// <summary>
 	/// Wraps configured serializer so that we can emit diagnostics per configured serializer.
 	/// </summary>
-	internal class DiagnosticsSerializerProxy : IElasticsearchSerializer, IInternalSerializerWithFormatter
+	internal class DiagnosticsSerializerProxy : IElasticsearchSerializer, IInternalSerializerWithFormatter, IInternalSerializer
 	{
 		private readonly IElasticsearchSerializer _serializer;
+		private readonly bool _wrapsUtf8JsonSerializer;
 		private readonly SerializerRegistrationInformation _state;
 		private readonly IJsonFormatterResolver _formatterResolver;
 		private static DiagnosticSource DiagnosticSource { get; } = new DiagnosticListener(DiagnosticSources.Serializer.SourceName);
@@ -47,11 +51,25 @@ public DiagnosticsSerializerProxy(IElasticsearchSerializer serializer, string pu
 			_serializer = serializer;
 			_state = new SerializerRegistrationInformation(serializer.GetType(), purpose);
 			if (serializer is IInternalSerializerWithFormatter withFormatter)
+			{
 				_formatterResolver = withFormatter.FormatterResolver;
+				_wrapsUtf8JsonSerializer = true;
+			}
+			else
+			{
+				_wrapsUtf8JsonSerializer = false;
+				_formatterResolver = null;
+			}
 		}
 
 		public IJsonFormatterResolver FormatterResolver => _formatterResolver;
 
+		public bool TryGetJsonFormatter(out IJsonFormatterResolver formatterResolver)
+		{
+			formatterResolver = _formatterResolver;
+			return _wrapsUtf8JsonSerializer;
+		}
+
 		public object Deserialize(Type type, Stream stream)
 		{
 			using (DiagnosticSource.Diagnose(DiagnosticSources.Serializer.Deserialize, _state))

src/Elasticsearch.Net/Serialization/ElasticsearchSerializerExtensions.cs

@@ -1,9 +1,23 @@
 using Elasticsearch.Net.Extensions;
+using Elasticsearch.Net.Utf8Json;
 
 namespace Elasticsearch.Net
 {
 	public static class ElasticsearchSerializerExtensions
 	{
+		internal static void SerializeUsingWriter<T>(this IElasticsearchSerializer serializer, ref JsonWriter writer, T body, IConnectionConfigurationValues settings, SerializationFormatting formatting)
+		{
+			if (serializer is IInternalSerializer s && s.TryGetJsonFormatter(out var formatterResolver))
+			{
+				JsonSerializer.Serialize(ref writer, body, formatterResolver);
+				return;
+			}
+
+			var memoryStreamFactory = settings.MemoryStreamFactory;
+			var bodyBytes = serializer.SerializeToBytes(body, memoryStreamFactory, formatting);
+			writer.WriteRaw(bodyBytes);
+		}
+
 		/// <summary>
 		/// Extension method that serializes an instance of <typeparamref name="T"/> to a byte array.
 		/// </summary>
@@ -65,5 +79,6 @@ public static string SerializeToString<T>(
 				return ms.Utf8String();
 			}
 		}
+
 	}
 }

src/Elasticsearch.Net/Serialization/IInternalSerializerWithFormatter.cs

@@ -1,9 +1,14 @@
 using Elasticsearch.Net.Utf8Json;
 
-namespace Elasticsearch.Net 
+namespace Elasticsearch.Net
 {
+	internal interface IInternalSerializer
+	{
+		bool TryGetJsonFormatter(out IJsonFormatterResolver formatterResolver);
+	}
+
 	internal interface IInternalSerializerWithFormatter
 	{
 		IJsonFormatterResolver FormatterResolver { get; }
 	}
-}
+}

src/Elasticsearch.Net/Serialization/LowLevelRequestResponseSerializer.cs

@@ -7,29 +7,23 @@
 
 namespace Elasticsearch.Net
 {
-	public class LowLevelRequestResponseSerializer : IElasticsearchSerializer
+	public class LowLevelRequestResponseSerializer : IElasticsearchSerializer, IInternalSerializerWithFormatter
 	{
+		IJsonFormatterResolver IInternalSerializerWithFormatter.FormatterResolver => null;
+
 		public static readonly LowLevelRequestResponseSerializer Instance = new LowLevelRequestResponseSerializer();
 
-		public object Deserialize(Type type, Stream stream)
-		{
-			return JsonSerializer.NonGeneric.Deserialize(type, stream, ElasticsearchNetFormatterResolver.Instance);
-		}
-
-		public T Deserialize<T>(Stream stream)
-		{
-			return JsonSerializer.Deserialize<T>(stream, ElasticsearchNetFormatterResolver.Instance);
-		}
-
-		public Task<object> DeserializeAsync(Type type, Stream stream, CancellationToken cancellationToken = default)
-		{
-			return JsonSerializer.NonGeneric.DeserializeAsync(type, stream, ElasticsearchNetFormatterResolver.Instance);
-		}
-
-		public Task<T> DeserializeAsync<T>(Stream stream, CancellationToken cancellationToken = default)
-		{
-			return JsonSerializer.DeserializeAsync<T>(stream, ElasticsearchNetFormatterResolver.Instance);
-		}
+		public object Deserialize(Type type, Stream stream) =>
+			JsonSerializer.NonGeneric.Deserialize(type, stream, ElasticsearchNetFormatterResolver.Instance);
+
+		public T Deserialize<T>(Stream stream) =>
+			JsonSerializer.Deserialize<T>(stream, ElasticsearchNetFormatterResolver.Instance);
+
+		public Task<object> DeserializeAsync(Type type, Stream stream, CancellationToken cancellationToken = default) =>
+			JsonSerializer.NonGeneric.DeserializeAsync(type, stream, ElasticsearchNetFormatterResolver.Instance);
+
+		public Task<T> DeserializeAsync<T>(Stream stream, CancellationToken cancellationToken = default) =>
+			JsonSerializer.DeserializeAsync<T>(stream, ElasticsearchNetFormatterResolver.Instance);
 
 		public void Serialize<T>(T data, Stream writableStream, SerializationFormatting formatting = SerializationFormatting.None) =>
 			JsonSerializer.Serialize(writableStream, data, ElasticsearchNetFormatterResolver.Instance);

src/Nest/CommonAbstractions/SerializationBehavior/JsonFormatters/SourceFormatter.cs

@@ -35,7 +35,7 @@ public T Deserialize(ref JsonReader reader, IJsonFormatterResolver formatterReso
 		/// `IInternalSerializerWithFormatter`
 		/// </summary>
 		private static bool AttemptFastPath(IElasticsearchSerializer serializer) =>
-			serializer is IInternalSerializerWithFormatter s && s.FormatterResolver != null;
+			serializer is IInternalSerializer s && s.TryGetJsonFormatter(out var _);
 
 
 		public virtual void Serialize(ref JsonWriter writer, T value, IJsonFormatterResolver formatterResolver)

src/Nest/Document/Multiple/Bulk/BulkRequestFormatter.cs

@@ -41,6 +41,13 @@ public void Serialize(ref JsonWriter writer, IBulkRequest value, IJsonFormatterR
 				if (body == null)
 					continue;
 
+				if (op.Operation == "update" || body is ILazyDocument)
+				{
+					var requestResponseSerializer = settings.RequestResponseSerializer;
+					requestResponseSerializer.SerializeUsingWriter(ref writer, body, settings, SerializationFormatting.None);
+					return;
+				}
+
 				SourceWriter.Serialize(ref writer, body, formatterResolver);
 				writer.WriteRaw(Newline);
 			}

src/Tests/Tests.Benchmarking/BenchmarkProgram.cs

@@ -30,15 +30,19 @@ static Program()
 			if (!Directory.Exists(Path.Combine(dirInfo.FullName, ".git"))) Environment.Exit(2);
 
 			Console.WriteLine(dirInfo.FullName);
-			using (var repos = new Repository(dirInfo.FullName))
+			try
 			{
+				using var repos = new Repository(dirInfo.FullName);
 				Commit = repos.Head.Tip.Sha;
 				CommitMessage = repos.Head.Tip.Message?.Trim(' ', '\t', '\r', '\n');
 				Branch = repos.Head.FriendlyName;
 				var remoteName = repos.Head.RemoteName;
 				Repository =
-					repos.Network.Remotes.FirstOrDefault(r => r.Name == remoteName)?.Url
-					?? repos.Network.Remotes.FirstOrDefault()?.Url;
+					repos.Network.Remotes.FirstOrDefault(r => r.Name == remoteName)?.Url;
+			}
+			catch (Exception)
+			{
+				// ignored, libgit not very linux friendly
 			}
 		}