N👩
Size: a a a
2020 June 18
IB
а теперь без создания потока
export function destroyTimer<T>(dueTime: number): MonoTypeOperatorFunction<T> {
return (source: Observable<T>) => source.lift(new DestroyTimerOperator(dueTime));
}
class DestroyTimerOperator<T> implements Operator<T, T> {
constructor(private dueTime: number) {}
call(subscriber: Subscriber<T>, source: any): TeardownLogic {
return source.subscribe(new DestroyTimerSubscriber(subscriber, this.dueTime));
}
}
class DestroyTimerSubscriber<T, R> extends OuterSubscriber<T, R> {
private id;
constructor(destination: Subscriber<any>, dueTime: number) {
super(destination);
this.id = setTimeout(() => this.complete(), dueTime);
}
unsubscribe() {
super.unsubscribe();
clearTimeout(this.id);
}
}считается? Технически я тут поток не создаю)
Вキ
export function destroyTimer<T>(dueTime: number): MonoTypeOperatorFunction<T> {
return (source: Observable<T>) => source.lift(new DestroyTimerOperator(dueTime));
}
class DestroyTimerOperator<T> implements Operator<T, T> {
constructor(private dueTime: number) {}
call(subscriber: Subscriber<T>, source: any): TeardownLogic {
return source.subscribe(new DestroyTimerSubscriber(subscriber, this.dueTime));
}
}
class DestroyTimerSubscriber<T, R> extends OuterSubscriber<T, R> {
private id;
constructor(destination: Subscriber<any>, dueTime: number) {
super(destination);
this.id = setTimeout(() => this.complete(), dueTime);
}
unsubscribe() {
super.unsubscribe();
clearTimeout(this.id);
}
}считается? Технически я тут поток не создаю)
CN
export function destroyTimer<T>(dueTime: number): MonoTypeOperatorFunction<T> {
return (source: Observable<T>) => source.lift(new DestroyTimerOperator(dueTime));
}
class DestroyTimerOperator<T> implements Operator<T, T> {
constructor(private dueTime: number) {}
call(subscriber: Subscriber<T>, source: any): TeardownLogic {
return source.subscribe(new DestroyTimerSubscriber(subscriber, this.dueTime));
}
}
class DestroyTimerSubscriber<T, R> extends OuterSubscriber<T, R> {
private id;
constructor(destination: Subscriber<any>, dueTime: number) {
super(destination);
this.id = setTimeout(() => this.complete(), dueTime);
}
unsubscribe() {
super.unsubscribe();
clearTimeout(this.id);
}
}считается? Технически я тут поток не создаю)
лифт че делает?:
Вキ
как ты так быстро написал?)
IB
как ты так быстро написал?)
я скопировал takeUntil с гитхаба)
Вキ
я скопировал takeUntil с гитхаба)
IB
и чуток его подшаманил
D
я скопировал takeUntil с гитхаба)
Вキ
export function destroyTimer<T>(dueTime: number): MonoTypeOperatorFunction<T> {
return (source: Observable<T>) => source.lift(new DestroyTimerOperator(dueTime));
}
class DestroyTimerOperator<T> implements Operator<T, T> {
constructor(private dueTime: number) {}
call(subscriber: Subscriber<T>, source: any): TeardownLogic {
return source.subscribe(new DestroyTimerSubscriber(subscriber, this.dueTime));
}
}
class DestroyTimerSubscriber<T, R> extends OuterSubscriber<T, R> {
private id;
constructor(destination: Subscriber<any>, dueTime: number) {
super(destination);
this.id = setTimeout(() => this.complete(), dueTime);
}
unsubscribe() {
super.unsubscribe();
clearTimeout(this.id);
}
}считается? Технически я тут поток не создаю)
IB
Calle Nord
лифт че делает?:
кнопку нажимаешь он тебя везет
ДМ
я скопировал takeUntil с гитхаба)
ты читер
ДМ
пошли к нам работать, выбью тебе 180
IB
ты читер
Чей-то? Это оптимизация, чтобы лифты руками не писать
IB
пошли к нам работать, выбью тебе 180
Ну если на 4 ставки только
ДМ
Ну если на 4 ставки только
шо то ты жадный
ДМ
я думал - деньги не главное
IB
шо то ты жадный
Я типа должен поменять работу чтобы меньше получать?