Automation Advisor
Vstest
Microsoft.VisualStudio.TestPlatform.CommunicationUtilities.DataCollection
DataCollectionTestCaseEventHandler

How to use DataCollectionTestCaseEventHandler class of Microsoft.VisualStudio.TestPlatform.CommunicationUtilities.DataCollection package

Best Vstest code snippet using Microsoft.VisualStudio.TestPlatform.CommunicationUtilities.DataCollection.DataCollectionTestCaseEventHandler

DataCollectionRequestHandler.cs

Source:DataCollectionRequestHandler.cs

...30        private static readonly object SyncObject = new object();31        private readonly ICommunicationManager communicationManager;32        private IMessageSink messageSink;33        private IDataCollectionManager dataCollectionManager;34        private IDataCollectionTestCaseEventHandler dataCollectionTestCaseEventHandler;35        private Task testCaseEventMonitorTask;36        private IDataSerializer dataSerializer;37        /// <summary>38        /// Use to cancel data collection test case events monitoring if test run is cancelled.39        /// </summary>40        private CancellationTokenSource cancellationTokenSource;41        /// <summary>42        /// Initializes a new instance of the <see cref="DataCollectionRequestHandler"/> class.43        /// </summary>44        /// <param name="messageSink">45        /// The message sink.46        /// </param>47        protected DataCollectionRequestHandler(IMessageSink messageSink)48            : this(49                new SocketCommunicationManager(),50                messageSink,51                DataCollectionManager.Create(messageSink),52                new DataCollectionTestCaseEventHandler(),53                JsonDataSerializer.Instance)54        {55            this.messageSink = messageSink;56        }57        /// <summary>58        /// Initializes a new instance of the <see cref="DataCollectionRequestHandler"/> class.59        /// </summary>60        /// <param name="communicationManager">61        /// The communication manager.62        /// </param>63        /// <param name="messageSink">64        /// The message sink.65        /// </param>66        /// <param name="dataCollectionManager">67        /// The data collection manager.68        /// </param>69        /// <param name="dataCollectionTestCaseEventHandler">70        /// The data collection test case event handler.71        /// </param>72        /// <param name="dataSerializer">73        /// Serializer for serialization and deserialization of the messages.74        /// </param>75        protected DataCollectionRequestHandler(76            ICommunicationManager communicationManager,77            IMessageSink messageSink,78            IDataCollectionManager dataCollectionManager,79            IDataCollectionTestCaseEventHandler dataCollectionTestCaseEventHandler,80            IDataSerializer dataSerializer)81        {82            this.communicationManager = communicationManager;83            this.messageSink = messageSink;84            this.dataCollectionManager = dataCollectionManager;85            this.dataSerializer = dataSerializer;86            this.dataCollectionTestCaseEventHandler = dataCollectionTestCaseEventHandler;87            this.cancellationTokenSource = new CancellationTokenSource();88        }89        /// <summary>90        /// Gets the singleton instance of DataCollectionRequestHandler.91        /// </summary>92        public static DataCollectionRequestHandler Instance { get; private set; }93        /// <summary>94        /// Creates singleton instance of DataCollectionRequestHandler.95        /// </summary>96        /// <param name="communicationManager">97        /// Handles socket communication.98        /// </param>99        /// <param name="messageSink">100        /// Message sink for sending messages to execution process.101        /// </param>102        /// <returns>103        /// The instance of <see cref="DataCollectionRequestHandler"/>.104        /// </returns>105        public static DataCollectionRequestHandler Create(106            ICommunicationManager communicationManager,107            IMessageSink messageSink)108        {109            if (Instance == null)110            {111                ValidateArg.NotNull(communicationManager, nameof(communicationManager));112                ValidateArg.NotNull(messageSink, nameof(messageSink));113                lock (SyncObject)114                {115                    if (Instance == null)116                    {117                        Instance = new DataCollectionRequestHandler(118                            communicationManager,119                            messageSink,120                            DataCollectionManager.Create(messageSink),121                            new DataCollectionTestCaseEventHandler(),122                            JsonDataSerializer.Instance);123                    }124                }125            }126            return Instance;127        }128        /// <inheritdoc />129        public void InitializeCommunication(int port)130        {131            this.communicationManager.SetupClientAsync(new IPEndPoint(IPAddress.Loopback, port));132        }133        /// <inheritdoc />134        public bool WaitForRequestSenderConnection(int connectionTimeout)135        {...