Skip to content

Commit 84a2c3d

Browse files
committed
make sure ILStreamReader uses stream manager
1 parent 69e507a commit 84a2c3d

File tree

3 files changed

+4
-3
lines changed

3 files changed

+4
-3
lines changed

src/Auxiliary/Elasticsearch.Net.VirtualizedCluster/FixedPipelineFactory.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@ public class FixedPipelineFactory : IRequestPipelineFactory
55
public FixedPipelineFactory(IConnectionConfigurationValues connectionSettings, IDateTimeProvider dateTimeProvider)
66
{
77
DateTimeProvider = dateTimeProvider;
8-
MemoryStreamFactory = new MemoryStreamFactory();
8+
MemoryStreamFactory = RecyclableMemoryStreamFactory.Default;
99

1010
Settings = connectionSettings;
1111
Pipeline = Create(Settings, DateTimeProvider, MemoryStreamFactory, new SearchRequestParameters());
@@ -16,7 +16,7 @@ public FixedPipelineFactory(IConnectionConfigurationValues connectionSettings, I
1616
public IRequestPipeline Pipeline { get; }
1717

1818
private IDateTimeProvider DateTimeProvider { get; }
19-
private MemoryStreamFactory MemoryStreamFactory { get; }
19+
private IMemoryStreamFactory MemoryStreamFactory { get; }
2020
private IConnectionConfigurationValues Settings { get; }
2121

2222
private Transport<IConnectionConfigurationValues> Transport =>

src/Elasticsearch.Net/Providers/MemoryStreamFactory.cs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@
22

33
namespace Elasticsearch.Net
44
{
5+
// TODO we use this in some places but its no longer clear to me why need to circumvent RecyclableMemoryStream in some cases
56
/// <summary>
67
/// A factory for creating memory streams using instances of <see cref="MemoryStream" />
78
/// </summary>

src/Elasticsearch.Net/Utf8Json/Internal/Emit/ILViewer.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,7 @@ static ILStreamReader()
6161
}
6262

6363
public ILStreamReader(byte[] ilByteArray)
64-
: base(new MemoryStream(ilByteArray))
64+
: base(RecyclableMemoryStreamFactory.Default.Create(ilByteArray))
6565
{
6666
this.endPosition = ilByteArray.Length;
6767
}

0 commit comments

Comments
 (0)