| | | 1 | | // Copyright (c) ZeroC, Inc. |
| | | 2 | | |
| | | 3 | | using System.Buffers; |
| | | 4 | | using System.IO.Pipelines; |
| | | 5 | | |
| | | 6 | | namespace IceRpc.Ice; |
| | | 7 | | |
| | | 8 | | /// <summary>Represents a property bag used to configure the encoding of payloads.</summary> |
| | | 9 | | public sealed class IceEncodeOptions |
| | | 10 | | { |
| | | 11 | | /// <summary>Gets the default instance of <see cref="IceEncodeOptions" />.</summary> |
| | 139 | 12 | | public static IceEncodeOptions Default { get; } = new(); |
| | | 13 | | |
| | | 14 | | /// <summary>Gets the pipe options that the IceRPC + Ice integration uses when creating pipes. The IceRPC + Ice |
| | | 15 | | /// integration creates a pipe when encoding a request or response payload, and when encoding an async enumerable |
| | | 16 | | /// into a <see cref="PipeReader" />.</summary> |
| | 137 | 17 | | public PipeOptions PipeOptions { get; } |
| | | 18 | | |
| | | 19 | | /// <summary>Constructs a new instance.</summary> |
| | | 20 | | /// <param name="pool">The pool parameter for the constructor of <see cref="System.IO.Pipelines.PipeOptions" />. |
| | | 21 | | /// </param> |
| | | 22 | | /// <param name="minimumSegmentSize">The minimum segment size for the constructor of |
| | | 23 | | /// <see cref="System.IO.Pipelines.PipeOptions" />.</param> |
| | 2 | 24 | | public IceEncodeOptions(MemoryPool<byte>? pool = default, int minimumSegmentSize = -1) => |
| | | 25 | | // We keep the default readerScheduler (ThreadPool) because pipes created from these PipeOptions are never |
| | | 26 | | // ReadAsync concurrently with a FlushAsync/Complete on the pipe writer. The writerScheduler does not matter |
| | | 27 | | // since FlushAsync never blocks. |
| | 2 | 28 | | PipeOptions = new( |
| | 2 | 29 | | pool: pool, |
| | 2 | 30 | | minimumSegmentSize: minimumSegmentSize, |
| | 2 | 31 | | pauseWriterThreshold: 0, |
| | 2 | 32 | | useSynchronizationContext: false); |
| | | 33 | | } |