Skip to content

Commit 9bdd3e6

Browse files
committed
Avoid indented formatting for Bulk request NDJSON
1 parent 525b781 commit 9bdd3e6

File tree

1 file changed

+8
-8
lines changed

1 file changed

+8
-8
lines changed

src/Elastic.Clients.Elasticsearch/Api/BulkRequest.cs

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -34,11 +34,11 @@ public void Serialize(Stream stream, IElasticsearchClientSettings settings, Seri
3434
foreach (var op in Operations)
3535
{
3636
if (op is not IStreamSerializable serializable)
37-
throw new InvalidOperationException("");
37+
throw new InvalidOperationException("Operation must implement IStreamSerializable.");
3838

3939
op.PrepareIndex(index);
4040

41-
serializable.Serialize(stream, settings, formatting);
41+
serializable.Serialize(stream, settings, SerializationFormatting.None);
4242
stream.WriteByte((byte)'\n');
4343
}
4444
}
@@ -53,11 +53,11 @@ public async Task SerializeAsync(Stream stream, IElasticsearchClientSettings set
5353
foreach (var op in Operations)
5454
{
5555
if (op is not IStreamSerializable serializable)
56-
throw new InvalidOperationException("");
56+
throw new InvalidOperationException("Operation must implement IStreamSerializable.");
5757

5858
op.PrepareIndex(index);
5959

60-
await serializable.SerializeAsync(stream, settings, formatting).ConfigureAwait(false);
60+
await serializable.SerializeAsync(stream, settings, SerializationFormatting.None).ConfigureAwait(false);
6161
stream.WriteByte((byte)'\n');
6262
}
6363
}
@@ -200,11 +200,11 @@ public void Serialize(Stream stream, IElasticsearchClientSettings settings, Seri
200200
foreach (var op in _operations)
201201
{
202202
if (op is not IStreamSerializable serializable)
203-
throw new InvalidOperationException("");
203+
throw new InvalidOperationException("Operation must implement IStreamSerializable.");
204204

205205
op.PrepareIndex(index);
206206

207-
serializable.Serialize(stream, settings, formatting);
207+
serializable.Serialize(stream, settings, SerializationFormatting.None);
208208
stream.WriteByte((byte)'\n');
209209
}
210210
}
@@ -219,11 +219,11 @@ public async Task SerializeAsync(Stream stream, IElasticsearchClientSettings set
219219
foreach (var op in _operations)
220220
{
221221
if (op is not IStreamSerializable serializable)
222-
throw new InvalidOperationException("");
222+
throw new InvalidOperationException("Operation must implement IStreamSerializable.");
223223

224224
op.PrepareIndex(index);
225225

226-
await serializable.SerializeAsync(stream, settings, formatting).ConfigureAwait(false);
226+
await serializable.SerializeAsync(stream, settings, SerializationFormatting.None).ConfigureAwait(false);
227227
stream.WriteByte((byte)'\n');
228228
}
229229
}

0 commit comments

Comments
 (0)