Click here to Skip to main content
Click here to Skip to main content
Add your own
alternative version
Go to top

WPF Extensibility Hacks or WEX - Includes EventTrigger, ReactiveTrigger, InvokeMethodAction, InvokeCommandAction etc.

, 14 Jan 2010
A set of extensibility hacks for WPF. A few interesting triggers and actions, including EventTrigger, ReactiveTrigger, InvokeMethodAction, and InvokeCommandAction. Also allows invoking Triggers and Actions based on Conditions.
Wex.zip
Assemblies
Microsoft.Expression.Interactions.dll
System.ComponentModel.Composition.dll
System.CoreEx.dll
System.Interactive.dll
System.Reactive.dll
System.Windows.Interactivity.dll
WexEventTrigger
ClassDiagram1.cd
Wex.csproj.user
bin
Debug
WexEventTrigger.dll
WexEventTrigger.vshost.exe
WexEventTrigger.vshost.exe.manifest
Composition
Lib
Properties
Settings.settings
Reactive
WexEventTrigger.Demo
bin
Debug
WexEventTrigger.Demo.vshost.exe
WexEventTrigger.Demo.vshost.exe.manifest
Commands
Extensions
Properties
Settings.settings
Views
Demos
using System;
using System.Net;
using System.Windows;
using System.Windows.Controls;
using System.Windows.Documents;
using System.Windows.Ink;
using System.Windows.Input;
using System.Windows.Media;
using System.Windows.Media.Animation;
using System.Windows.Shapes;
using System.Collections.Generic;
using System.Reflection;
using System.Globalization;
using System.Collections.ObjectModel;
using System.Reflection.Emit;
using System.Threading;

namespace Wex.Lib.Reactive
{
    #region Internal Classes from System.Reactive

    internal class AnonymousDisposable : IDisposable
    {
        // Fields
        private Action dispose;

        // Methods
        public AnonymousDisposable(Action dispose)
        {
            this.dispose = dispose;
        }

        public void Dispose()
        {
            this.dispose();
        }
    }

    internal class AnonymousObservable<T> : IObservable<T>
    {
        // Fields
        private Func<IObserver<T>, IDisposable> subscribe;

        // Methods
        public AnonymousObservable(Func<IObserver<T>, IDisposable> subscribe)
        {
            this.subscribe = subscribe;
        }

        public IDisposable Subscribe(IObserver<T> observer)
        {
            AsyncSubject<IDisposable> signal = new AsyncSubject<IDisposable>();
            var arg = new AutoDetachObserver(observer, signal);
            IDisposable disposable = this.subscribe(arg);
            signal.OnNext(disposable);
            return disposable;
        }

        // Nested Types
        private class AutoDetachObserver : AbstractObserver<T>
        {
            // Fields
            private IObserver<T> observer;
            private IObservable<IDisposable> signal;

            // Methods
            public AutoDetachObserver(IObserver<T> observer, IObservable<IDisposable> signal)
            {
                this.observer = observer;
                this.signal = signal;
            }

            protected override void Completed()
            {
                this.observer.OnCompleted();
                this.signal.Subscribe<IDisposable>(delegate(IDisposable d)
                {
                    d.Dispose();
                });
            }

            protected override void Error(Exception exception)
            {
                this.observer.OnError(exception);
                this.signal.Subscribe<IDisposable>(delegate(IDisposable d)
                {
                    d.Dispose();
                });
            }

            protected override void Next(T value)
            {
                this.observer.OnNext(value);
            }
        }
    }

    internal abstract class AbstractObserver<T> : IObserver<T>
    {
        // Fields
        private bool isStopped;

        // Methods
        public AbstractObserver()
        {
            this.isStopped = false;
        }

        protected abstract void Completed();
        protected abstract void Error(Exception exception);
        protected abstract void Next(T value);
        public void OnCompleted()
        {
            if (!this.isStopped)
            {
                this.isStopped = true;
                this.Completed();
            }
        }

        public void OnError(Exception exception)
        {
            if (!this.isStopped)
            {
                this.isStopped = true;
                this.Error(exception);
            }
        }

        public void OnNext(T value)
        {
            if (!this.isStopped)
            {
                this.Next(value);
            }
        }
    }

    #endregion
}

By viewing downloads associated with this article you agree to the Terms of Service and the article's licence.

If a file you wish to view isn't highlighted, and is a text file (not binary), please let us know and we'll add colourisation support for it.

License

This article, along with any associated source code and files, is licensed under The Code Project Open License (CPOL)

Share

About the Author


| Advertise | Privacy | Mobile
Web04 | 2.8.140905.1 | Last Updated 14 Jan 2010
Article Copyright 2010 by Anoop Madhusudanan
Everything else Copyright © CodeProject, 1999-2014
Terms of Service
Layout: fixed | fluid