Fun with Rx

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.ComponentModel.Composition.Hosting;
using System.ComponentModel.Composition;

namespace MefRX
{
    public sealed  class SimpleComposer
    {
        #region Data

        static readonly SimpleComposer instance = new SimpleComposer();
 
        #endregion

        #region Ctor
        static SimpleComposer()
        { 
            
        }

        private SimpleComposer()
        {
            
        }
        #endregion

        #region Public Methods
        /// <summary>
        /// Resolve an exported function
        /// </summary>
        /// <param name="name"></param>
        /// <returns></returns>
        public static Func<object, IObservable<EventArgsWrapper>> Resolve(string name)
        {
            var rxSenders = Instance.RxEventExporters;

            if (rxSenders == null) throw new InvalidOperationException(
                "Part composer not initialized");
            try
            {
                return Instance.RxEventExporters.FirstOrDefault(
                    s => s.Metadata.ExportableName == name).Value;
            }
            catch (Exception ex)
            {
                return null;
            }
        }


        public void Compose()
        {
            var catalog = new AggregateCatalog();
            catalog.Catalogs.Add(new AssemblyCatalog(
                System.Reflection.Assembly.GetExecutingAssembly()));
            var container = new CompositionContainer(catalog);
            container.ComposeParts(Instance);

        }
        #endregion

        #region Public Properties

        [ImportMany]
        public Lazy<Func<object, IObservable<EventArgsWrapper>>, 
            IExportableName>[] RxEventExporters { get; set; }


        public static SimpleComposer Instance
        {
            get
            {
                return instance;
            }
        }
        #endregion
    }
}