force handler functions
Some checks failed
Pull request change / publish (pull_request) Failing after 10s
Some checks failed
Pull request change / publish (pull_request) Failing after 10s
This commit is contained in:
@@ -1,44 +1,44 @@
|
||||
import { Stream } from 'stream';
|
||||
import { Stream } from "stream";
|
||||
|
||||
export class Interactor {
|
||||
_actions = new Stream();
|
||||
_reactions = new Stream();
|
||||
_latestReaction;
|
||||
#actions = new Stream();
|
||||
#reactions = new Stream();
|
||||
#latestReaction;
|
||||
#latestReactions = {};
|
||||
|
||||
constructor(initialReaction = new Reaction()) {
|
||||
this._latestReactions = {};
|
||||
this._actions.listen((action) => this._interaction(action));
|
||||
this.#actions.listen((action) =>
|
||||
this[`handle${action.constructor.name}`](action)
|
||||
);
|
||||
this._react(initialReaction);
|
||||
}
|
||||
|
||||
act(action) {
|
||||
if (!(action instanceof Action)) throw 'invalid action';
|
||||
this._actions.add(action);
|
||||
if (!(action instanceof Action)) throw "invalid action";
|
||||
this.#actions.add(action);
|
||||
}
|
||||
|
||||
observe(reactionHandler, provideLatestReaction = true) {
|
||||
if (provideLatestReaction) reactionHandler(this._latestReaction);
|
||||
if (provideLatestReaction) reactionHandler(this.#latestReaction);
|
||||
let listener = (reaction) => {
|
||||
if (!(reaction instanceof Reaction)) throw 'invalid reaction';
|
||||
if (!(reaction instanceof Reaction)) throw "invalid reaction";
|
||||
reactionHandler(reaction);
|
||||
};
|
||||
this._reactions.listen(listener);
|
||||
this.#reactions.listen(listener);
|
||||
return listener;
|
||||
}
|
||||
|
||||
ignore(listener) {
|
||||
this._reactions.ignore(listener);
|
||||
this.#reactions.ignore(listener);
|
||||
}
|
||||
|
||||
_interaction(action) {}
|
||||
|
||||
_react(reaction) {
|
||||
if (!(reaction instanceof Reaction)) throw 'invalid reaction';
|
||||
let latest = this._latestReactions[reaction.constructor.name];
|
||||
if (!(reaction instanceof Reaction)) throw "invalid reaction";
|
||||
let latest = this.#latestReactions[reaction.constructor.name];
|
||||
if (!reaction.equals(latest)) {
|
||||
this._latestReaction = reaction;
|
||||
this._latestReactions[reaction.constructor.name] = reaction;
|
||||
this._reactions.add(reaction);
|
||||
this.#latestReaction = reaction;
|
||||
this.#latestReactions[reaction.constructor.name] = reaction;
|
||||
this.#reactions.add(reaction);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user