alxhub

function trackQueryEvents(queries: Observable<Query[]>): Observable<QueryEvent> {
  var oldQueries = [];
  return queries.flatMap((queries: Query[]) => {
    var res = Observable.fromArray([]
    .concat(queries
      .filter(query =>
        oldQueries.find(oldQuery => oldQuery.match(query)) === undefined)
      .map(query => {event: 'added', query}))
    .concat(oldQueries
      .filter(oldQuery => queries.find(query => query.match(oldQuery)) === undefined)

alxhub

import {Injectable} from 'angular2/core';
import {Store, Action} from '@ngrx/store';
import {Query} from './query';

interface QueryEvent {
  type: string;
  query: Query;
}

function trackQueryEvents(queries: Observable<Query[]>): Observable<QueryEvent> {

alxhub

[   85.472247] [<800256f8>] (warn_slowpath_null) from [<80410298>] (bcm2835_mmc_transfer_dma+0x1a8/0x1e0)
[   85.485867] [<80410298>] (bcm2835_mmc_transfer_dma) from [<80411324>] (bcm2835_mmc_request+0xa8/0xc0)
[   85.498750] [<80411324>] (bcm2835_mmc_request) from [<803f9aa8>] (mmc_start_request+0xd4/0xf8)
[   85.511034] [<803f9aa8>] (mmc_start_request) from [<803fa834>] (mmc_start_req+0x2a8/0x37c)
[   85.523053] [<803fa834>] (mmc_start_req) from [<804090a4>] (mmc_blk_issue_rw_rq+0xc8/0xafc)
[   85.535168] [<804090a4>] (mmc_blk_issue_rw_rq) from [<80409bdc>] (mmc_blk_issue_rq+0x104/0x4d8)
[   85.547683] [<80409bdc>] (mmc_blk_issue_rq) from [<8040aedc>] (mmc_queue_thread+0xb8/0x158)
[   85.559891] [<8040aedc>] (mmc_queue_thread) from [<8003ffa0>] (kthread+0xe0/0xfc)
[   85.571240] [<8003ffa0>] (kthread) from [<8000eb88>] (ret_from_fork+0x14/0x20)
[   85.580610] ---[ end trace f869ecbd2c135221 ]---

alxhub

$ kubectl get nodes
NAME            LABELS                                 STATUS    AGE
192.168.7.100   kubernetes.io/hostname=192.168.7.100   Ready     8h
192.168.7.101   kubernetes.io/hostname=192.168.7.101   Ready     8h
192.168.7.102   kubernetes.io/hostname=192.168.7.102   Ready     8h
192.168.7.103   kubernetes.io/hostname=192.168.7.103   Ready     8h
192.168.7.104   kubernetes.io/hostname=192.168.7.104   Ready     8h

alxhub

getUser(id: string) {
  return store
    .select('user')
    .do((user) => {
      if (!user) {
        triggerHttpCallToLoadUser();
      }
    })
    .skipWhile(user => user == undefined)
    .take(1);

alxhub

$ ./blur ls /
d alpha
d beta
$ ./blur mkdir /beta/test
$ ./blur ls /beta
d test
$ ./blur ls -R
/:
d alpha
d beta

alxhub

var Builder = require('systemjs-builder');

var b = (new Builder());
b.config({
  map: {
    app: 'src',
    'deep-assign': 'node_modules/deep-assign',
    'is-obj': 'node_modules/is-obj'
  },
  packages: {

alxhub

var Builder = require('systemjs-builder');

var b = (new Builder());
b.config({
  map: {
    app: 'src',
    'deep-assign': 'node_modules/deep-assign',
    'is-obj': 'node_modules/is-obj'
  },
  packages: {

alxhub

@Component({
  selector: 'view-post',
  template: `
<comment-list *ngIf="post | async" [postId]="(post | async)?.id"></comment-list>
`
})
export class ViewPost {
  post: Observable<IPost>
  constructor() {
    this.post = this

alxhub

import {Observable} from 'rxjs/Rx';

import {Manifest, ManifestParser, ManifestDelta, GroupDelta, ManifestGroup} from './manifest';

let EMPTY_GROUP = new ManifestGroup();

function _keys(...objs: Object[]): string[] {
  let keys = {};
  objs.forEach(obj => Object
    .keys(obj)