import { Effect } from '@rxdi/core'; import { PubSubService } from '@rxdi/graphql-pubsub'; import { OfType } from '@rxdi/graphql'; import { EffectTypes } from '../core/api-introspection/EffectTypes'; import { UserType } from './types/user.type'; import { UserInfo } from '../core/services/auth/auth.service'; @Effect() export class UserEffect { constructor( private pubSub: PubSubService ) {} @OfType(EffectTypes.findUser) findUser(result: UserType, { id }, context: { user: UserInfo }) { this.pubSub.publish('CREATE_SIGNAL_BASIC', 'hello World'); console.log(result, id, context); } }