How to use FilteringMessageSink class of Xunit.Runner.v2 package

...182		{183			Guard.ArgumentNotNull(messageSink);184			Guard.ArgumentNotNull(settings);185			var includeSourceInformation = settings.Options.GetIncludeSourceInformationOrDefault();186			var filteringMessageSink = new FilteringMessageSink(messageSink, settings.Filters.Filter);187			// TODO: We're missing a potential optimization where we could determine that the filter188			// is exactly 1 (or maybe only?) "include class" filters, and then call the version of189			// Find on the remote discoverer that takes a type name.190			SendDiscoveryStartingMessage(messageSink);191			remoteDiscoverer.Find(192				includeSourceInformation,193				CreateOptimizedRemoteMessageSink(filteringMessageSink),194				Xunit2OptionsAdapter.Adapt(settings.Options)195			);196		}197		/// <inheritdoc/>198		public void FindAndRun(199			_IMessageSink messageSink,200			FrontControllerFindAndRunSettings settings)201		{202			Guard.NotNull($"This instance of {typeof(Xunit2).FullName} was created for discovery only; execution-related operations cannot be performed.", remoteExecutor);203			Guard.ArgumentNotNull(messageSink);204			Guard.ArgumentNotNull(settings);205			if (settings.Filters.Empty)206			{207				remoteExecutor.RunAll(208					CreateOptimizedRemoteMessageSink(messageSink),209					Xunit2OptionsAdapter.Adapt(settings.DiscoveryOptions),210					Xunit2OptionsAdapter.Adapt(settings.ExecutionOptions)211				);212				return;213			}214			using var discoverySink = new Xunit2DiscoverySink(settings.Filters);215			remoteDiscoverer.Find(216				includeSourceInformation: false,217				discoverySink,218				Xunit2OptionsAdapter.Adapt(settings.DiscoveryOptions)219			);220			discoverySink.Finished.WaitOne();221			remoteExecutor.RunTests(222				discoverySink.TestCases,223				CreateOptimizedRemoteMessageSink(messageSink),224				Xunit2OptionsAdapter.Adapt(settings.ExecutionOptions)225			);226		}227		static string GetExecutionAssemblyFileName(AppDomainSupport appDomainSupport, string basePath)228		{229			var supportedPlatformSuffixes = GetSupportedPlatformSuffixes(appDomainSupport);230			foreach (var suffix in supportedPlatformSuffixes)231			{232#if NETFRAMEWORK233				var fileName = Path.Combine(basePath, $"xunit.execution.{suffix}.dll");234				if (File.Exists(fileName))235					return fileName;236#else237				try238				{239					var assemblyName = $"xunit.execution.{suffix}";240					Assembly.Load(new AssemblyName { Name = assemblyName });241					return assemblyName + ".dll";242				}243				catch { }244#endif245			}246			throw new InvalidOperationException("Could not find/load any of the following assemblies: " + string.Join(", ", supportedPlatformSuffixes.Select(suffix => $"xunit.execution.{suffix}.dll").ToArray()));247		}248		static string[] GetSupportedPlatformSuffixes(AppDomainSupport appDomainSupport)249		{250#if NETFRAMEWORK251			return appDomainSupport == AppDomainSupport.Required ? SupportedPlatforms_ForcedAppDomains : SupportedPlatforms;252#else253			return SupportedPlatforms;254#endif255		}256		static AssemblyName GetTestFrameworkAssemblyName(string xunitExecutionAssemblyPath)257		{258#if NETFRAMEWORK259			return AssemblyName.GetAssemblyName(xunitExecutionAssemblyPath);260#else261			// Make sure we only use the short form262			return Assembly.Load(new AssemblyName { Name = Path.GetFileNameWithoutExtension(xunitExecutionAssemblyPath), Version = new Version(0, 0, 0, 0) }).GetName();263#endif264		}265		static string GetXunitExecutionAssemblyPath(266			AppDomainSupport appDomainSupport,267			string assemblyFileName,268			bool verifyTestAssemblyExists)269		{270			Guard.ArgumentNotNullOrEmpty(assemblyFileName);271			if (verifyTestAssemblyExists)272				Guard.FileExists(assemblyFileName);273			return GetExecutionAssemblyFileName(appDomainSupport, Path.GetDirectoryName(assemblyFileName)!);274		}275		static string GetXunitExecutionAssemblyPath(276			AppDomainSupport appDomainSupport,277			_IAssemblyInfo assemblyInfo)278		{279			Guard.ArgumentNotNull(assemblyInfo);280			Guard.ArgumentNotNullOrEmpty(assemblyInfo.AssemblyPath);281			return GetExecutionAssemblyFileName(appDomainSupport, Path.GetDirectoryName(assemblyInfo.AssemblyPath)!);282		}283#if NETFRAMEWORK284		static bool IsDotNet(string executionAssemblyFileName) =>285			executionAssemblyFileName.EndsWith(".dotnet.dll", StringComparison.Ordinal);286#endif287		/// <inheritdoc/>288		public void Run(289			_IMessageSink messageSink,290			FrontControllerRunSettings settings)291		{292			Guard.NotNull($"This instance of {typeof(Xunit2).FullName} was created for discovery only; execution-related operations cannot be performed.", remoteExecutor);293			Guard.ArgumentNotNull(messageSink);294			Guard.ArgumentNotNull(settings);295			remoteExecutor.RunTests(296				BulkDeserialize(settings.SerializedTestCases.ToList()).Select(kvp => kvp.Value).ToList(),297				CreateOptimizedRemoteMessageSink(messageSink),298				Xunit2OptionsAdapter.Adapt(settings.Options)299			);300		}301		void SendDiscoveryStartingMessage(_IMessageSink messageSink)302		{303			// There is no v2 equivalent to this, so we manufacture it ourselves304			var discoveryStarting = new _DiscoveryStarting305			{306				AssemblyName = assemblyInfo.Name,307				AssemblyPath = assemblyInfo.AssemblyPath,308				AssemblyUniqueID = UniqueIDGenerator.ForAssembly(assemblyInfo.Name, assemblyInfo.AssemblyPath, configFileName),309				ConfigFilePath = configFileName310			};311			messageSink.OnMessage(discoveryStarting);312		}313		// Factory methods314		/// <summary>315		/// Returns an implementation of <see cref="IFrontControllerDiscoverer"/> which can be used316		/// to discover xUnit.net v2 tests, including source-based discovery.317		/// </summary>318		/// <param name="assemblyInfo">The assembly to use for discovery</param>319		/// <param name="projectAssembly">The test project assembly.</param>320		/// <param name="xunitExecutionAssemblyPath">The path on disk of xunit.execution.*.dll; if <c>null</c>, then321		/// the location of xunit.execution.*.dll is implied based on the location of the test assembly</param>322		/// <param name="sourceInformationProvider">The optional source information provider.</param>323		/// <param name="diagnosticMessageSink">The message sink which receives <see cref="_DiagnosticMessage"/> messages.</param>324		/// <param name="verifyAssembliesOnDisk">Determines whether or not to check for the existence of assembly files.</param>325		public static IFrontControllerDiscoverer ForDiscovery(326			_IAssemblyInfo assemblyInfo,327			XunitProjectAssembly projectAssembly,328			string? xunitExecutionAssemblyPath = null,329			_ISourceInformationProvider? sourceInformationProvider = null,330			_IMessageSink? diagnosticMessageSink = null,331			bool verifyAssembliesOnDisk = true)332		{333			var appDomainSupport = projectAssembly.Configuration.AppDomainOrDefault;334			Guard.ArgumentNotNull(assemblyInfo);335			return new Xunit2(336				diagnosticMessageSink ?? _NullMessageSink.Instance,337				appDomainSupport,338				sourceInformationProvider ?? _NullSourceInformationProvider.Instance,  // TODO: Need to find a way to be able to use VisualStudioSourceInformationProvider339				assemblyInfo,340				assemblyFileName: null,341				xunitExecutionAssemblyPath ?? GetXunitExecutionAssemblyPath(appDomainSupport, assemblyInfo),342				projectAssembly.ConfigFileName,343				projectAssembly.Configuration.ShadowCopyOrDefault,344				projectAssembly.Configuration.ShadowCopyFolder,345				verifyAssembliesOnDisk346			);347		}348		/// <summary>349		/// Returns an implementation of <see cref="IFrontController"/> which can be used350		/// for both discovery and execution of xUnit.net v2 tests.351		/// </summary>352		/// <param name="projectAssembly">The test project assembly.</param>353		/// <param name="sourceInformationProvider">The optional source information provider.</param>354		/// <param name="diagnosticMessageSink">The message sink which receives <see cref="_DiagnosticMessage"/> messages.</param>355		/// <param name="verifyAssembliesOnDisk">Determines whether or not to check for the existence of assembly files.</param>356		public static IFrontController ForDiscoveryAndExecution(357			XunitProjectAssembly projectAssembly,358			_ISourceInformationProvider? sourceInformationProvider = null,359			_IMessageSink? diagnosticMessageSink = null,360			bool verifyAssembliesOnDisk = true)361		{362			Guard.ArgumentNotNull(projectAssembly);363			var appDomainSupport = projectAssembly.Configuration.AppDomainOrDefault;364			var assemblyFileName = Guard.ArgumentNotNull(projectAssembly.AssemblyFileName);365			if (diagnosticMessageSink == null)366				diagnosticMessageSink = _NullMessageSink.Instance;367			return new Xunit2(368				diagnosticMessageSink,369				appDomainSupport,370#if NETSTANDARD371				sourceInformationProvider ?? _NullSourceInformationProvider.Instance,372#else373				sourceInformationProvider ?? new VisualStudioSourceInformationProvider(assemblyFileName, diagnosticMessageSink),374#endif375				assemblyInfo: null,376				assemblyFileName,377				GetXunitExecutionAssemblyPath(appDomainSupport, assemblyFileName, verifyAssembliesOnDisk),378				projectAssembly.ConfigFileName,379				projectAssembly.Configuration.ShadowCopyOrDefault,380				projectAssembly.Configuration.ShadowCopyFolder,381				verifyAssembliesOnDisk382			);383		}384		// Inner classes385		class DescriptorCallback : LongLivedMarshalByRefObject386		{387			public List<string>? Results;388			public void Callback(List<string> results) => Results = results;389		}390		class DeserializeCallback : LongLivedMarshalByRefObject391		{392			public List<KeyValuePair<string?, ITestCase?>>? Results;393			public void Callback(List<KeyValuePair<string?, ITestCase?>> results) => Results = results;394		}395		class FilteringMessageSink : _IMessageSink396		{397			readonly Predicate<_TestCaseDiscovered> filter;398			readonly _IMessageSink innerMessageSink;399			public FilteringMessageSink(400				_IMessageSink innerMessageSink,401				Predicate<_TestCaseDiscovered> filter)402			{403				this.innerMessageSink = innerMessageSink;404				this.filter = filter;405			}406			public bool OnMessage(_MessageSinkMessage message)407			{408				if (message is _TestCaseDiscovered discovered)409					if (!filter(discovered))410						return true;411				return innerMessageSink.OnMessage(message);412			}413		}...

1using System;2using System.Collections.Generic;3using System.Linq;4using System.Text;5using Xunit;6using Xunit.Abstractions;7using Xunit.Runner.v2;8{9    {10        public static void Main(string[] args)11        {12            var assemblyFileName = args[0];13            var testMethod = args[1];14            var assembly = AssemblyHelper.Load(assemblyFileName);15            using (var controller = new XunitFrontController(assemblyFileName, assemblyFileName, configFileName: null))16            {17                using (var discoverySink = new TestDiscoverySink())18                {19                    controller.Find(includeSourceInformation: false, messageSink: discoverySink, discoveryOptions: TestFrameworkOptions.ForDiscovery());20                    discoverySink.Finished.WaitOne();21                    var filters = new List<IFilter>();22                    filters.Add(new TestMethodFilter(testMethod));23                    var filter = new CompositeFilter(filters);24                    using (var executionSink = new TestExecutionSink())25                    {26                        controller.RunTests(discoverySink.TestCases.Where(tc => filter(tc)), executionSink, TestFrameworkOptions.ForExecution());27                        executionSink.Finished.WaitOne();28                    }29                }30            }31        }32    }33}34xUnit.net Console Runner (64-bit .NET 4.0.30319.42000)

1using System;2using System.Collections.Generic;3using System.Linq;4using System.Text;5using Xunit;6using Xunit.Abstractions;7using Xunit.Runner.v2;8{9    {10        public static void Main(string[] args)11        {12            var assemblyFileName = args[0];13            var testMethod = args[1];14            var assembly = AssemblyHelper.Load(assemblyFileName);15            using (var controller = new XunitFrontController(assemblyFileName, assemblyFileName, configFileName: null))16            {17                using (var discoverySink = new TestDiscoverySink())18                {19                    controller.Find(includeSourceInformation: false, messageSink: discoverySink, discoveryOptions: TestFrameworkOptions.ForDiscovery());20                    discoverySink.Finished.WaitOne();21                    var filters = new List<IFilter>();22                    filters.Add(new TestMethodFilter(testMethod));23                    var filter = new CompositeFilter(filters);24                    using (var executionSink = new TestExecutionSink())25                    {26                        controller.RunTests(discoverySink.TestCases.Where(tc => filter(tc)), executionSink, TestFrameworkOptions.ForExecution());27                        executionSink.Finished.WaitOne();28                    }29                }30            }31        }32    }33}34xUnit.net Console Runner (64-bit .NET 4.0.30319.42000)

1using Xunit.Runner.v2;2using Xunit.Runner.v2.Filters;3using Xunit.Runner.v2.Sinks;4using Xunit.Sdk;5[assembly: TestFramework("Xunit.Runner.v2.TestFrameworkProxy", "Xunit.Runner.v2")]6[assembly: TestFramework("Xunit.Runner.v2.TestFrameworkProxy", "Xunit.Runner.v2")]7{8    {9        public TestFrameworkProxy(IMessageSink messageSink) : base(messageSink)10        {11        }12        protected override ITestFrameworkExecutor CreateExecutor(AssemblyName assemblyName)13        {14            return new TestFrameworkExecutorProxy(assemblyName, SourceInformationProvider, DiagnosticMessageSink);15        }16    }17    {18        public TestFrameworkExecutorProxy(AssemblyName assemblyName, ISourceInformationProvider sourceInformationProvider, IMessageSink diagnosticMessageSink) : base(assemblyName, sourceInformationProvider, diagnosticMessageSink)19        {20        }21        protected override IEnumerable<ITestCase> EnumerateTestCases(IMethodInfo testMethod)22        {23            return new[] { new TestCaseProxy(testMethod) };24        }25    }26    {27        readonly IMethodInfo _method;28        public TestCaseProxy(IMethodInfo method)29        {30            _method = method;31        }32        public IMethodInfo Method { get { return _method; } }33        public string DisplayName { get { return _method.Name; } }34        public string SkipReason { get { return null; } }35        public ISourceInformation SourceInformation { get { return null; } }36        public ITypeInfo Type { get { return _method.Type; } }37        public ITestMethod Deserialize(ITestMethodResolver testMethodResolver)38        {39            return testMethodResolver.GetTestMethod(_method);40        }41        public void Serialize(IXunitSerializationInfo data)42        {43            throw new NotImplementedException();44        }45    }46}47using Xunit.Runner.v2;48using Xunit.Runner.v2.Filters;49using Xunit.Runner.v2.Sinks;50using Xunit.Sdk;51[assembly: TestFramework("Xunit.Runner.v2.TestFrameworkProxy", "Xunit.Runner.v2")]52[assembly: TestFramework("Xunit.Runner.v2.TestFrameworkProxy",

1using Xunit.Runner.v2;2using Xunit.Runner.v2.Filters;3using Xunit.Runner.v2.TestAdapter;4using Xunit.Sdk;5using Xunit.v3;6using Xunit.v3.Execution;7using Xunit.v3.Runner;8{9    {10        readonly string assemblyFileName;11        readonly _IMessageSink innerSink;12        readonly _ITestCaseFilter filter;13        public FilteringMessageSink(_IMessageSink innerSink, _ITestCaseFilter filter)14        {15            this.innerSink = innerSink;16            this.filter = filter;17        }18        public FilteringMessageSink(_IMessageSink innerSink, string assemblyFileName, _IDiscoveryOptions discoveryOptions)19        {20            this.assemblyFileName = assemblyFileName;21            this.filter = TestFrameworkOptionsFilter.Create(assemblyFileName, discoveryOptions);22        }23using System.Text;24using Xunit.Abstractions;25using Xunit.Runner.v2;26using Xunit.Sdk;27using Xunit;28using Xunit.ConsoleClient;29using Xunit.Runner.Common;30using System.Threading.Tasks;31using System.IO;32using Xunit.Runner.v2;33using Xunit.Runner.Common;34using Xunit.Runner.Reporters;35using Xunit.Runner.v2;36using Xunit.Runner.Common;37using Xunit.Runner.Reporters;38{39    {40        public static void Main(string[] args)41        {42            Console.WriteLine("Hello World!");43            Console.WriteLine("Press enter to start");44            Console.ReadLine();45            var assemblyFileName = @"C:\Users\mike\Documents\Visual Studio 2015\Projects\ConsoleApp1\ClassLibrary1\bin\Debug\ClassLibrary1.dll";46            var configFileName = @"C:\Users\mike\Documents\Visual Studio 2015\Projects\ConsoleApp1\ConsoleApp1\app.config";47            var assembly = Assembly.LoadFrom(assemblyFileName);48            var config = ConfigReader.Load(configFileName);49            var sink = new DelegatingTestMessageSink(new TestMessageSink());50            var runner = new XunitTestAssemblyRunner(new XunitTestAssembly(assembly, config), new[] { sink });51            var testCollection = runner.TestAssembly.TestCollections.First();52            var testCases = testCollection.Tests;53            var traitFilter = new TraitFilter(new Dictionary<string, List<string>> { { "Category", new List<string> { "Unit" } } });54            var filteredTestCases = traitFilter.Filter(testCases).ToList();55            var filteredRunner = new XunitTestAssemblyRunner(new XunitTestAssembly(assembly, config), new[] { sink });56            filteredRunner.RunTestCollectionAsync(testCollection, filteredTestCases).Wait();57        }58    }59}60using System;61using System.Collections.Generic;62using System.Linq;63using System.Text;64using Xunit.Abstractions;65using Xunit.Runner.v2;66using Xunit.Sdk;67using Xunit;68using Xunit.ConsoleClient;69using Xunit.Runner.Common;70using System.Threading.Tasks;71using System.IO;72using Xunit.Runner.v2;73using Xunit.Runner.Common;74using Xunit.Runner.Reporters;75using Xunit.Runner.v2;

1using System;2using System.Collections.Generic;3using System.Linq;4using System.Text;5using System.Threading.Tasks;6using Xunit;7using Xunit.Abstractions;8{9    {10        private readonly ITestOutputHelper _output;11        public TestClass1(ITestOutputHelper output)12        {13            _output = output;14        }15        public void Test1()16        {17            _output.WriteLine("Test1");18        }19        public void Test2()20        {21            _output.WriteLine("Test2");22        }23        public void Test3()24        {25            _output.WriteLine("Test3");26        }27        public void Test4()28        {29            _output.WriteLine("Test4");30        }31        public void Test5()32        {33            _output.WriteLine("Test5");34        }35    }36}37using System;38using System.Collections.Generic;39using System.Linq;40using System.Text;41using System.Threading.Tasks;42using Xunit;43using Xunit.Abstractions;44{45    [Trait("Category", "UnitTest")]46    {47        private readonly ITestOutputHelper _output;48        public TestClass1(ITestOutputHelper output)49        {50            _output = output;51        }52        public void Test1()53        {54            _output.WriteLine("Test1");55        }56        public void Test2()57        {58            _output.WriteLine("Test2");59        }60        public void Test3()61        {62            _output.WriteLine("Test3");63        }64        public void Test4()65        {66            _output.WriteLine("Test4");67        }68        public void Test5()69        {70            _output.WriteLine("Test5");71        }72    }iscoveryOptions = Test

1using Xunit.Runner.v2;2using Xunit.Runner.Common;3using Xunit.Sdk;4using Xunit;5using System.Collections.Generic;6using System.Linq;7using System.Reflection;8using System;9using Xunit.Abstractions;10using System.Collections.ObjectModel;11using Xunit.Runner.2;12using Xunit.Runn.Common;13using Xunit.Sdk;14using Sstem.Threading.Tasks;15using System.Threading;16using System.I;17using Xunit.Runner.v2;18using Xunit.Runner.Common;19{20    {21        public static void Main(string[] args)22        {23            var configuration = ConfigReader.Load();24            var assemblyFileName = configuration.AssemblyFileName;25            var assembly = Assembly.LoadFrom(assemblyFileName);26            var testCases = GetTestCases(assembly);27            var fileredTestCases = FlterTestCases(testCases, cfiguration);28            var tetAssemblyRunner new TestAssemblyRunner(29}30using System;31using System.Collections.Generic;32using System.Linq;33using System.Text;34using System.Threading.Tasks;35using Xunit;36using Xunit.Abstractions;37{38    [Trait("Category

1var assemblyFileName = "C:\\Users\\user\\Desktop\\xunit\\5\\5.Test\\bin\\Debug\\netcoreapp2.0\\5.Test.dll";2var assembly = Assembly.LoadFrom(assemblyFileName);3var config = ConfigReader.Load();4var diagnosticMessageSink = new DiagnosticMessageSink();5var discoveryOptions = TestFrameworkOptions.ForDiscovery(config);6var discoverySink = new TestDiscoverySink();7var discovery = new XunitTestFrameworkDiscoverer(assembly, discoveryOptions, diagnosticMessageSink);8discovery.Find(includeSourceInformation: false, discoverySink, TestFrameworkOptions.ForDiscovery(config));9var testCases = discoverySink.TestCases;10var executionOptions = TestFrameworkOptions.ForExecution(config);11var executionSink = new ExecutionSummarySink();12var execution = new XunitTestFrameworkExecutor(assembly, executionOptions, diagnosticMessageSink);13execution.RunTests(testCases, executionSink, executionOptions);14var summary = executionSink.ExecutionSummary;15Console.WriteLine(summary);16var assemblyFileName = "C:\\Users\\user\\Desktop\\xunit\\5\\5.Test\\bin\\Debug\\netcoreapp2.0\\5.Test.dll";17var assembly = Assembly.LoadFrom(assemblyFileName);18var config = ConfigReader.Load();19var diagnosticMessageSink = new DiagnosticMessageSink();20var discoveryOptions = TestFrameworkOptions.ForDiscovery(config);21var discoverySink = new TestDiscoverySink();22var discovery = new XunitTestFrameworkDiscoverer(assembly, discoveryOptions, diagnosticMessageSink);23discovery.Find(includeSourceInformation: false, discoverySink, TestFrameworkOptions.ForDiscovery(config));24var testCases = discoverySink.TestCases;25var executionOptions = TestFrameworkOptions.ForExecution(config);26var executionSink = new ExecutionSummarySink();27var execution = new XunitTestFrameworkExecutor(assembly, executionOptions, diagnosticMessageSink);28execution.RunTests(testCases, executionSink, executionOptions);29var summary = executionSink.ExecutionSummary;30Console.WriteLine(summary);31var assemblyFileName = "C:\\Users\\user\\Desktop\\xunit\\6\\6.Test\\bin\\Debug\\netcoreapp2.0\\6.Test.dll";32var assembly = Assembly.LoadFrom(assemblyFileName);33var config = ConfigReader.Load();34var diagnosticMessageSink = new DiagnosticMessageSink();

1using Xunit.Runner.v2;2using Xunit.Runner.Common;3using Xunit.Sdk;4using Xunit;5using System.Collections.Generic;6using System.Linq;7using System.Reflection;8using System;9using Xunit.Abstractions;10using System.Collections.ObjectModel;11using Xunit.Runner.v2;12using Xunit.Runner.Common;13using Xunit.Sdk;14using System.Threading.Tasks;15using System.Threading;16using System.IO;17using Xunit.Runner.v2;18using Xunit.Runner.Common;19{20    {21        public static void Main(string[] args)22        {23            var configuration = ConfigReader.Load();24            var assemblyFileName = configuration.AssemblyFileName;25            var assembly = Assembly.LoadFrom(assemblyFileName);26            var testCases = GetTestCases(assembly);27            var filteredTestCases = FilterTestCases(testCases, configuration);28            var testAssemblyRunner = new TestAssemblyRunner(