<commit_before>import { Observable } from 'rxjs/Observable'
import { Subscriber } from 'rxjs/Subscriber'
import 'rxjs/add/observable/interval';
import 'rxjs/add/operator/take';
import 'rxjs/add/operator/scan';
import { Component, Inject } from 'ng-metadata/core';

@Component({
  selector: 'async-task',
  template: (
    `Clock: {{ $ctrl.clock$ | async | date:'M/d/yy h:mm:ss a' }} <br>
     Timer: {{ $ctrl.timer$ | async:this }} <br>
     Async Stream via scan:
     <ul><li ng-repeat="u in $ctrl.stream$ | async:this">{{ u }}</li></ul>`
  )
})
class AsyncTaskComponent {

  clock$ = Observable.create((observer: Subscriber<number>) => {<commit_msg>fix(playground/async-example): add this to async observable<commit_after>import { Observable } from 'rxjs/Observable'
import { Subscriber } from 'rxjs/Subscriber'
import 'rxjs/add/observable/interval';
import 'rxjs/add/operator/take';
import 'rxjs/add/operator/scan';
import { Component, Inject } from 'ng-metadata/core';

@Component({
  selector: 'async-task',
  template: (
    `Clock: {{ $ctrl.clock$ | async:this | date:'M/d/yy h:mm:ss a' }} <br>
     Timer: {{ $ctrl.timer$ | async:this }} <br>
     Async Stream via scan:
     <ul><li ng-repeat="u in $ctrl.stream$ | async:this">{{ u }}</li></ul>`
  )
})
class AsyncTaskComponent {

  clock$ = Observable.create((observer: Subscriber<number>) => {
{'fraction_non_alphanumeric': 0.18450184501845018, 'fraction_numerical': 0.0, 'mean_word_length': 4.380952380952381, 'pattern_counts': {'":': 0, '<': 17, '<?xml version=': 0, '>': 19, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '2276565', 'n_tokens_mistral': 469, 'n_tokens_neox': 459, 'n_words': 105}