dotnet/taobao-sdk-netcore-auto_1719572210878-20240628-source/Generated/TopLink/Channel/TCP/TcpServerChannelSender.cs

using System;
using System.Collections.Generic;
using System.Net.Sockets;
using System.Text;

namespace Taobao.Top.Link.Channel.TCP
{
    /// <summary>the channel that can send message to client via raw tcp
    /// </summary>
    public class TcpServerChannelSender : IServerChannelSender
    {
        private IDictionary<object, object> _context;
        TcpClient _tcpClient;

        public bool IsOpen
        {
            get { return this._tcpClient.Connected; }
        }

        public TcpServerChannelSender(TcpClient tcpClient)
        {
            this._tcpClient = tcpClient;
            this._context = new Dictionary<object, object>();
        }

        public object GetContext(object key)
        {
            object val;
            return this._context.TryGetValue(key, out val) ? val : null;
        }
        public void SetContext(object key, object value)
        {
            this._context[key] = value;
        }

        public void Send(byte[] data)
        {
            this._tcpClient.GetStream().Write(data, 0, data.Length);
        }
        public void Close(string reason)
        {
            this._tcpClient.Close();
        }
    }
}