MyCaffeGymUiProxy.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.ServiceModel;
using System.ServiceModel.Description;
using System.Text;
using System.Threading.Tasks;
 
namespace MyCaffe.gym
{
    public class MyCaffeGymUiProxy : DuplexClientBase<IXMyCaffeGymUiService>       
    {
        object m_sync = new object();
        bool m_bOpen = false;
 
        public MyCaffeGymUiProxy(InstanceContext ctx, NetNamedPipeBinding binding = null)
            : base(ctx, new ServiceEndpoint(ContractDescription.GetContract(typeof(IXMyCaffeGymUiService)),
                   (binding == null) ? new NetNamedPipeBinding() : binding, new EndpointAddress("net.pipe://localhost/MyCaffeGym/gymui")))
        {
        }
 
        public int OpenUi(string strName, int nId, bool bStartRecording = false)
        {
            m_bOpen = true;
            return Channel.OpenUi(strName, nId, bStartRecording);
        }
 
        public void CloseUi(int nId)
        {
            lock (m_sync)
            {
                Channel.CloseUi(nId);
                m_bOpen = false;
            }
        }
 
        public void Render(int nId, Observation obs)
        {
            try
            {
                lock (m_sync)
                {
                    if (!m_bOpen)
                        return;
 
                    Channel.Render(nId, obs);
                }
            }
            catch
            {
            }
        }
 
        public bool IsOpen(int nId)
        {
            return Channel.IsOpen(nId);
        }
    }
}