             // Subscribe to the work.
             work.multicast(buffer).connect()
         }
-
+        
+        self._executionObservables.onNext(work)
+        
         buffer.subscribe(onNext: { element in
                     self._elements.onNext(element)
                 },

        return self._executing.asObservable().observeOn(MainScheduler.instance)
    }
    private let _executing = Variable(false)

    /// Whether or not we're enabled. Note that this is a *computed* sequence
    /// property based on enabledIf initializer and if we're currently executing.
    /// Always observed on MainScheduler.

import RxCocoa

/// Typealias for compatibility with UIButton's rx_action property.
public typealias CocoaAction = Action<Void, AnyObject?>

/// Possible errors from invoking execute()
public enum ActionError: ErrorType {
