timeout.js

import { ApolloLink, Observable } from 'apollo-link'

export class TimeoutLink extends ApolloLink {
  constructor({ interval } = { interval: 1000 }) {
    this.interval = interval;
  }

  request(operation, forward){
    return new Observable(obs, => {

      const handler = {
        next: obs.next.bind(obs),
        error: obs.error.bind(obs),
        complete: obs.complete.bind(obs)
      }
      
      let attempt = forward(operation);
      let sub = attempt.subscribe(handler);

      const timeout = setTimeout(() => {
        if (sub) sub.unsubscribe();
        attempt = forward(operation);
        let sub = attempt.subscribe(handler);
      }, this.interval)

      return () => {
        if (sub) sub.unsubscribe()
        if (timeout) clearTimeout(timeout)
      }
    })
  }
}