| | | 1 | | // Copyright (c) ZeroC, Inc. |
| | | 2 | | |
| | | 3 | | using IceRpc.Transports.Coloc.Internal; |
| | | 4 | | using System.Collections.Concurrent; |
| | | 5 | | |
| | | 6 | | namespace IceRpc.Transports.Coloc; |
| | | 7 | | |
| | | 8 | | /// <summary>The Coloc transport class provides a client and server duplex transport that can be used for in-process |
| | | 9 | | /// communications.</summary> |
| | | 10 | | public sealed class ColocTransport |
| | | 11 | | { |
| | | 12 | | /// <summary>The transport name.</summary> |
| | | 13 | | public const string Name = "coloc"; |
| | | 14 | | |
| | | 15 | | /// <summary>Gets the colocated client transport.</summary> |
| | | 16 | | /// <value>The client transport.</value> |
| | 520 | 17 | | public IDuplexClientTransport ClientTransport { get; } |
| | | 18 | | |
| | | 19 | | /// <summary>Gets the colocated server transport.</summary> |
| | | 20 | | /// <value>The server transport.</value> |
| | 528 | 21 | | public IDuplexServerTransport ServerTransport { get; } |
| | | 22 | | |
| | | 23 | | /// <summary>Constructs a <see cref="ColocTransport" />.</summary> |
| | | 24 | | public ColocTransport() |
| | 37 | 25 | | : this(new ColocTransportOptions()) |
| | 37 | 26 | | { |
| | 37 | 27 | | } |
| | | 28 | | |
| | | 29 | | /// <summary>Constructs a <see cref="ColocTransport" />.</summary> |
| | | 30 | | /// <param name="options">The options to configure the Coloc transport.</param> |
| | 509 | 31 | | public ColocTransport(ColocTransportOptions options) |
| | 509 | 32 | | { |
| | 509 | 33 | | var listeners = new ConcurrentDictionary<(string Host, ushort Port), ColocListener>(); |
| | 509 | 34 | | ClientTransport = new ColocClientTransport(listeners, options); |
| | 509 | 35 | | ServerTransport = new ColocServerTransport(listeners, options); |
| | 509 | 36 | | } |
| | | 37 | | } |