Example how NS support async pipe with RxObservable.

ng-sample/app/list-test-async.ts

@@ -0,0 +1,58 @@
+import { Component, Input, ChangeDetectionStrategy } from 'angular2/core';
+import { Observable as RxObservable } from 'rxjs/Observable';
+import { Observable, WrappedValue } from 'data/observable';
+
+class DataItem {
+    constructor(public id: number, public name: string) { }
+}
+
+@Component({
+    selector: 'list-test-async',
+    template: `
+            <ListView [items]="myItems | async" (itemTap)="onItemTap($event)">
+                <item-template>
+                    <template #item="item" #i="index" #odd="odd" #even="even">
+                        <StackLayout [class.odd]="odd" [class.even]="even">
+                            <Label [text]='"index: " + item.name'></Label>
+                        </StackLayout>
+                    </template>
+                </item-template>
+            </ListView>
+    `,
+    changeDetection: ChangeDetectionStrategy.OnPush
+})
+export class ListTestAsync {
+    public myItems: RxObservable<Array<DataItem>>;
+
+    constructor() {
+        var items = [];
+        for (var i = 0; i < 3; i++) {
+            items.push(new DataItem(i, "data item " + i));
+        }
+
+        var subscr;
+        this.myItems = RxObservable.create(subscriber => {
+            subscr = subscriber;
+            subscriber.next(WrappedValue.wrap(items));
+            return function () {
+                console.log("Unsubscribe called!!!");
+            }
+        });
+
+        let counter = 2;
+        let intervalId = setInterval(() => {
+            counter++;
+            console.log("Adding " + counter + "-th item");
+            items.push(new DataItem(counter, "data item " + counter));
+            subscr.next(WrappedValue.wrap(items));
+        }, 1000);
+
+        setTimeout(() => {
+            clearInterval(intervalId);   
+        }, 15000);
+    }
+
+    public onItemTap(args) {
+        console.log("------------------------ ItemTapped: " + args.index);
+    }
+}

ng-sample/app/main-page.ts

@@ -6,7 +6,8 @@ import {Page} from 'ui/page';
 import {nativeScriptBootstrap} from './nativescript-angular/application';
 // import {RendererTest} from './renderer-test';
 //import {Benchmark} from './benchmark';
-import {ListTest} from './list-test';
+//import {ListTest} from './list-test';
+import {ListTestAsync} from './list-test-async';
 
 export function createPage() {
     var page = new Page();
@@ -19,7 +20,8 @@ export function createPage() {
         console.log('BOOTSTRAPPING...');
         //nativeScriptBootstrap(Benchmark, []).then((appRef) => {
         // nativeScriptBootstrap(RendererTest, []).then((appRef) => {
-        nativeScriptBootstrap(ListTest, []).then((appRef) => {
+        //nativeScriptBootstrap(ListTest, []).then((appRef) => {
+        nativeScriptBootstrap(ListTestAsync, []).then((appRef) => {
             profiling.stop('ng-bootstrap');
             console.log('ANGULAR BOOTSTRAP DONE.');
         }, (err) =>{