PhotonTrueSyncCommunicator.cs

using System;

namespace TrueSync {

    public class PhotonTrueSyncCommunicator : ICommunicator {

        private LoadBalancingPeer loadBalancingPeer;

        private static PhotonNetwork.EventCallback lastEventCallback;

        internal PhotonTrueSyncCommunicator(LoadBalancingPeer loadBalancingPeer) {
            this.loadBalancingPeer = loadBalancingPeer;
        }

        public int RoundTripTime() {
            return loadBalancingPeer.RoundTripTime;
        }

        public void OpRaiseEvent(byte eventCode, object message, bool reliable, int[] toPlayers) {
            if (loadBalancingPeer.PeerState != ExitGames.Client.Photon.PeerStateValue.Connected) {
                return;
            }

            RaiseEventOptions eventOptions = new RaiseEventOptions();
            eventOptions.TargetActors = toPlayers;

            loadBalancingPeer.OpRaiseEvent(eventCode, message, reliable, eventOptions);
        }

        public void AddEventListener(OnEventReceived onEventReceived) {
            if (lastEventCallback != null) {
                PhotonNetwork.OnEventCall -= lastEventCallback;
            }

            lastEventCallback = delegate (byte eventCode, object content, int senderId) { onEventReceived(eventCode, content); };
            PhotonNetwork.OnEventCall += lastEventCallback;
        }

    }

}