Observe Subscriptions

observe.js

import { Observable } from 'rxjs/Observable'
import { SubscriptionClient } from 'subscriptions-transport-ws'
const ws = new SubscriptionClient("endpointurl")

const observable = Observable.create(observer => {
    const id = this.ws.subscribe(graphQLParams, (err, res) => {
        if (err) {
            observer.next(res)
            observer.unsubscribe()
        }
        observer.next(res)
    })

    return () => {
        ws.unsubscribe(id)
    }
})

const subscription = observable.subscribe({
    next: data => {
        console.log('data', data)
    },
    error: error => {
        console.error(error)
    },
    complete: () => {
        console.log('subscription complete')
    },
})