Class Actor<TMessage>

Protected answer

• answer(...messages: Observable<Event<any> & AnswerConfig<Event<any>>>[]): void

• Subscribes to an observable of events when there is an emission will send the event to a recipient (actor reference) when specified and to itself when not. completes when stop message is send to the actor.

  Example

  import { Actor, createEvent } from 'reactive-actor';

  export const getUsers = createEvent('[Users] Get Users');

  export const getUsersSuccess = createEvent<GitHubUser[]>( '[Users] Get Users Success' );

  export const getUsersFail = createEvent('[Users] Get Users Fail');

  export type UsersActorEvents = ReturnType;

  export class UsersActor extends Actor { // Reference to logger actor private readonly logger = new Actor('logger');

  // Recipient is not define thus will send the resulting event to itself private readonly getUsers$ = this.messages$.pipe( ofType(getUsers), exhaustMap(() => ajax<GitHubUser[]>(https://api.github.com/users?per_page=5).pipe( map(({ response }) => getUsersSuccess(response)), catchError((err) => of(getUsersFail(err))) ) ) );

  // Recipient is define thus will send event (getUsersFail) to specified recipient (logger) private readonly getUsersFail$ = this.messages$.pipe( ofType(getUsersFail), addRecipient(this.logger) );

  constructor() { super('users'); this.answer(this.getUsers$, this.getUsersFail$); } }

  Parameters

  • Rest ...messages: Observable<Event<any> & AnswerConfig<Event<any>>>[]

    an observable of messages

  Returns void