ContactRequestAccepted.js

import EventStream from './EventStream'

export default {
  ...EventStream,
  subscribe: ({ iterator, updater }) =>
    EventStream.subscribe({
      iterator:
        iterator &&
        function * () {
          try {
            while (true) {
              const response = yield
              if (response.EventStream.kind === 'ContactRequestAccepted') {
                iterator.next(response.EventStream)
              }
            }
          } catch (error) {
            iterator.error(error)
          }
          iterator.return()
        },
      updater:
        updater &&
        ((store, data) => {
          if (data.EventStream.kind === 'ContactRequestAccepted') {
            return updater(store, data.EventStream)
          }
        }),
    }),
}