using System;
using System.Collections.Generic;
using System.Linq;
using System.Reactive.Linq;
using System.Text;
using System.Threading.Tasks;
using Google.Protobuf;
using Tango.Transport.Adapters;
using Tango.PMR;
using Tango.PMR.Common;
using System.Collections.Concurrent;
using System.Reactive.Subjects;
using System.Threading;
using System.Reactive;
using System.Reactive.Disposables;
using Tango.Logging;

namespace Tango.Transport.Transporters
{
    /// <summary>
    /// Represents an <see cref="ITransporter"/> which send and receive <see cref="TangoMessage{T}"/> messages using Protobuf binary data.
    /// </summary>
    /// <seealso cref="Tango.Transport.TransporterBase" />
    public class BasicTransporter : TransporterBase
    {
        #region Constructors

        /// <summary>
        /// Initializes a new instance of the <see cref="BasicTransporter"/> class.
        /// </summary>
        public BasicTransporter() : base()
        {
            ComponentName = $"Basic Transporter {_component_counter++}";
        }

        /// <summary>
        /// Initializes a new instance of the <see cref="BasicTransporter"/> class.
        /// </summary>
        /// <param name="adapter">The transport adapter.</param>
        public BasicTransporter(ITransportAdapter adapter) : base(adapter)
        {

        }

        #endregion
    }
}