called during WM_NCCREATE

Atomically add 's' to the set of subscriptions. If unsubscribe() has already occurred, this immediately calls s.unsubscribe(). cs.unsubscribe() [mus

! Return a new observable that contains the blocking methods for this observable. \return An observable that contains the blocking methods for t

! Return a new observable that performs type-forgetting conversion of this observable. \return The source observable converted to observable<T>.

performs type-forgetting conversion to a new grouped_observable

performs type-forgetting conversion to a new composite_observable

! \brief For each item from this observable reduce it by adding to the previous values and then dividing by the number of items at the end. \retu

! Return the average value of all items emitted by this blocking_observable, or throw an std::runtime_error exception if it emits no items. \

Atomically clear all subscriptions that were observably added (and not subsequently observably removed). Un-atomically call unsubscribe on those subs