可分解
这个项目之所以可能,是因为
Subscriptable软件包是一个简单的页面,可以让您能够使类子被允许向订阅者发送事件. 这仅仅是通过继承可分层分类来完成的.
制作基本分册
import {
Subscribable,
Subscription,
SubscribableEvent,
} from '@benzinga/subscribable';
interface SetAddEvents extends SubscribableEvent<'add'> { // one of the events that can be dispatched
item: number;
}
interface SetRemoveEvents { // second event that can be dispatched as you can see you don't have to implement SubscribableEvent directly all SubscribableEvent is doing is simply adding type key with the value given
type: 'remove';
item: number;
}
type SetEvents = SetAddEvents | SetRemoveEvents; // all the events that can be fired by the subscribable
class SetSubscribable extends Subscribable<SetEvents> { // extending the subscribable and telling the subscribable when events can be fired
private items = new Set<number>();
public add = (num: number ): void => {
this.items.add(num);
this.dispatch({type: 'add', item: num}); // fire out the event inherited from Subscribable
}
public remove = (num: number ): void => {
this.items.delete(num);
this.dispatch({type: 'remove', item: num}); // fire out the event inherited from Subscribable
}
}
type SetSubscription = ReturnType<SetSubscribable['subscribe']>; // this is a helper type that represents value returned from the
使用基本分册
import SetSubscribable from './set';
const set = new SetSubscribable(); // create a new instance
const setSubscribe1 = set.subscribe(event => { // subscribe to events
switch (event.type) {
case 'add':
console.log(`added ${event.item}`);
break;
case 'remove':
console.log(`removed ${event.item}`);
break;
}
})
const setSubscribe2: SetSubscription = set.subscribe(event => { // subscribe to events
switch (event.type) {
case 'add':
console.log(`included ${event.item}`);
break;
case 'remove':
console.log(`erased ${event.item}`);
break;
}
})
console.log('start');
set.add(1);
set.remove(1);
setSubscribe1.unsubscribe(); // unsubscribe the first subscription
console.log('unsubscribe');
set.add(2);
set.remove(2);
setSubscribe2.update(event => console.log('update')); // update the callback of the subscription
set.add(3);
set.remove(3);
setSubscribe2.unsubscribe(); // unsubscribe the second subscription
console.log('end');
这将产生以下产出
[LOG]: "start"
[LOG]: "added 1"
[LOG]: "included 1"
[LOG]: "removed 1"
[LOG]: "erased 1"
[LOG]: "unsubscribe"
[LOG]: "included 2"
[LOG]: "erased 2"
[LOG]: "update"
[LOG]: "update"
[LOG]: "end"
类订阅
这个 Subscription 类以通义为输入.
Events: 仅如上所示
class SetSubscribable extends Subscription<SetEvents>
发送
protected dispatch(event : Events) => void
- 这个功能是受保护的,可以让班级开火/发送出新的事件.
订阅
public subscribe(callback: (event: Events) => void, ..._args: readonly unknown[]) => Subscription<Events>
- 这是公众的功能, 它会回来
Subscription用于两者unsubscribe财务报告和审定财务报表update召回电话.
第一次订阅
protected onFirstSubscription = () => void;
- 继承等级
Subscribable也可以执行onFirstSubscription。如果您想要在初始化某物之前等待订阅者,则此功能是有用的.
零订阅
protected onZeroSubscriptions = () => void;
- 继承等级
Subscribable也可以执行onZeroSubscriptions。如果在没有订阅者的情况下想要进行一些清理,则此功能是有用的.
订阅
protected onSubscribe = (..._args: readonly unknown[]): void;
- 页:1
onSubscribe允许您在添加新的订阅者时运行您想要的任意类型的逻辑.
取消订阅
protected onUnsubscribe = () => void;
- 继承等级
Subscribable也可以执行onUnsubscribe。如果想要跟踪订阅者的数量,此选项将有所帮助。 您可以使用constructor调用和减少这里.
扩展订阅类
这个 ExtendedSubscription 继承从 Subscription 课取出两个同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同名同.
Events: 仅如上所示Extension: 表示将延长订阅时间。 比如说
interface SetExtends {
add: (num: number ) => void
remove: (num: number ) => void
}
class SetSubscribable extends ExtendedSubscription<SetEvents, SetExtends>
这将显示返回的订阅将拥有 add 财务报告和审定财务报表 remove 可调用函数。 完成这个任务 您需要返回 SetExtends 输入 onSubscription 以后再谈这个.
类 Subscription 对 ExtendedSubscription
ExtendedSubscription 仅仅是 Subscription ,其中的订阅函数已被超载以添加返回的数据 onSubscription 将添加到订阅的返回中.
订阅
public subscribe(callback: (event: Events) => void, ..._args: readonly unknown[]) => Subscription<Events, Extension>
- 这是公众的功能, 它会回来
Subscription用于两者unsubscribe财务报告和审定财务报表update召回电话。 还将包括:Extended函数返回.
订阅
protected onSubscribe = (..._args: readonly unknown[]): Extension
- 页:1
onSubscribe允许您在添加新订阅器但类型返回时运行您想要的任意类型的逻辑Extension需要时间.
interface SetExtends {
add: (num: number ) => void
remove: (num: number ) => void
}
class SetSubscribable extends ExtendedSubscription<SetEvents, SetExtends> {
onSubscribe = () => ({ // remember that () => ({}) is shorthand for () => { return {}}
open: this.open,
remove: this.remove,
})
}
这将允许您拨打 add 财务报告和审定财务报表 remove 编辑 Subscription 打电话后返回 subscribe
如果您只希望订阅者设置为 add 财务报告和审定财务报表 remove 可以简单制作的项目 private 在课堂上。 评估这些功能的唯一方法是通过 Subscription。 。 。 .
进行基本的扩展订阅
import {
Subscribable,
Subscription,
SubscribableEvent,
} from '@benzinga/subscribable';
interface SetAddEvents extends SubscribableEvent<'add'> { // one of the events that can be dispatched
item: number;
}
interface SetRemoveEvents { // second event that can be dispatched as you can see you don't have to implement SubscribableEvent directly all SubscribableEvent is doing is simply adding type key with the value given
type: 'remove';
item: number;
}
type SetEvents = SetAddEvents | SetRemoveEvents; // all the events that can be fired by the subscribable
interface SetSubscribableFunctions {
add: (num: number) => void;
remove: (num: number) => void
}
class SetSubscribable extends ExtendedSubscribable<SetEvents, SetSubscribableFunctions> { // extending the subscribable and telling the subscribable when events can be fired
private items = new Set<number>();
private add = (num: number ): void => { // note i made add protected to make sure that only subscribers can add
this.items.add(num);
this.dispatch({type: 'add', item: num}); // fire out the event inherited from Subscribable
}
private remove = (num: number ): void => { // note i made add protected to make sure that only subscribers can remove
this.items.delete(num);
this.dispatch({type: 'remove', item: num}); // fire out the event inherited from Subscribable
}
protected onSubscribe = () => ({
add: this.add,
remove: this.remove,
})
}
type SetSubscription = ReturnType<SetSubscribable['subscribe']>; // this is a helper type that represents value returned from the
使用基本分册
import SetSubscribable from './set';
const set = new SetSubscribable(); // create a new instance
const setSubscribe1 = set.subscribe(event => { // subscribe to events
switch (event.type) {
case 'add':
console.log(`added ${event.item}`);
break;
case 'remove':
console.log(`removed ${event.item}`);
break;
}
})
const setSubscribe2: SetSubscription = set.subscribe(event => { // subscribe to events
switch (event.type) {
case 'add':
console.log(`included ${event.item}`);
break;
case 'remove':
console.log(`erased ${event.item}`);
break;
}
})
console.log('start');
setSubscribe1.add(1);
setSubscribe1.remove(1);
setSubscribe1.unsubscribe(); // unsubscribe the first subscription
console.log('unsubscribe');
setSubscribe1.add(2);
setSubscribe1.remove(2);
setSubscribe2.update(event => console.log('update')); // update the callback of the subscription
setSubscribe2.add(3);
setSubscribe2.remove(3);
setSubscribe2.unsubscribe(); // unsubscribe the second subscription
console.log('end');
可拆卸
这个库是用 无。 。 。 .
运行单元测试
运行 nx test utils-subscribable 通过 欢乐。 。 。 .