fix(connectObs): unsubscribe from observables when unmounting

.prettierrc

@@ -0,0 +1,4 @@
+semi: false
+trailingComma: all
+printWidth: 80
+singleQuote: true

src/__tests__/connectObs.test.js

@@ -143,4 +143,28 @@ describe('connectObs', () => {
     )
     expect(wrapper.equals(<div className="foo" />)).toBeTruthy()
   })
+
+  it('unsubscribes from observables when the enhanced component is unmounted', () => {
+    const spy = jest.fn()
+    const spyUnsubscribe = observable =>
+      Rx.Observable.create(observer => {
+        const subscription = observable.subscribe(observer)
+        return () => {
+          spy()
+          subscription.unsubscribe()
+        }
+      })
+
+    const Component = compose(
+      connectObs(({ props$ }) => ({
+        foo: spyUnsubscribe(Rx.Observable.never()),
+        props: spyUnsubscribe(props$),
+      })),
+    )('div')
+
+    const wrapper = shallow(<Component />)
+    expect(spy).toHaveBeenCalledTimes(0)
+    wrapper.unmount()
+    expect(spy).toHaveBeenCalledTimes(2)
+  })
 })

src/connectObs.js

@@ -62,9 +62,11 @@ const connectObs = obsMapper =>
   withObs(observables => {
     const nextProps$ = createObservable(observer => {
       const obsMap = obsMapper(observables)
-      checkObsMap(obsMap)
-      let props
       const obsProps = {}
+      const obsSubscriptions = []
+      let props
+
+      checkObsMap(obsMap)
 
       const update = () => {
         if (props) {
@@ -84,23 +86,34 @@ const connectObs = obsMapper =>
           const observable = obsConfig.toESObservable(obsMap[key])
           checkObservable(observable, key)
           obsProps[key] = undefined
-          observable.subscribe({
+          const subscription = observable.subscribe({
             next(value) {
               obsProps[key] = value
               update()
             },
             error: asyncThrow,
           })
+
+          obsSubscriptions.push(subscription)
         }
       })
 
-      obsConfig.toESObservable(observables.props$).subscribe({
-        next(nextProps) {
-          props = nextProps
-          update()
-        },
-        error: asyncThrow,
-      })
+      const propsSubscription = obsConfig
+        .toESObservable(observables.props$)
+        .subscribe({
+          next(nextProps) {
+            props = nextProps
+            update()
+          },
+          error: asyncThrow,
+        })
+
+      return () => {
+        propsSubscription.unsubscribe()
+        obsSubscriptions.forEach(subscription => {
+          subscription.unsubscribe()
+        })
+      }
     })
 
     return { props$: nextProps$ }