stream: moved 'unsubscribe' function from nested inside observable's subscribe function to a property of a subscriber; improved unsubscribe function by removing need for closure; renamed 'dest' subscriber property to 'subscriber'; renamed 'subscribers' property to 'subscriptions'; made only root, underlying observable operate on promises as it was making the error/complete/unsubscribe process difficult
stream: moved 'unsubscribe' function from nested inside observable's subscribe function to a property of a subscriber; improved unsubscribe function by removing need for closure; renamed 'dest' subscriber property to 'subscriber'; renamed 'subscribers' property to 'subscriptions'; made only root, underlying observable operate on promises as it was making the error/complete/unsubscribe process difficult

mosbymc/queryable-js,mosbymc/pointfree-js