function test2() {

  const subMouseMove = new Rx.Subject<number>();

​

  const obLeft = subMouseMove.filter(m => m < 0);

  const obRight = subMouseMove.filter(m => m >= 0);

​

  const get_obLeftUntilRight = () => obLeft.takeUntil(obRight);

  const get_obRightUntilLeft = () => obRight.takeUntil(obLeft);

​

  //const get_obShake = () => Rx.Observable.race(get_obLeftUntilRight(), get_obRightUntilLeft()); 

​

  const obDragShakeAndDrop = Rx.Observable.concat(

    get_obLeftUntilRight().do(...getDebug("get_obShake1")),

    get_obRightUntilLeft().do(...getDebug("get_obShake2")),

  );

​

  var subscription = obDragShakeAndDrop.subscribe(

    x => debug('>> NEXT: ' + x),

    e => debug('>> ERROR: ' + e.message + "<div><pre>" + e.stack + "</pre></div>"),

    () => debug('>> COMPLETE<hr />')

  );

​

  let t = 10;

  setTimeout(() => subMouseMove.next(-1), t = t + 10);

  setTimeout(() => subMouseMove.next(-2), t = t + 10);

  setTimeout(() => subMouseMove.next(+3), t = t + 10);

  setTimeout(() => subMouseMove.next(+4), t = t + 10);

  setTimeout(() => subMouseMove.next(-5), t = t + 10);

}

​

function debug(s:string) {

  const divResults = document.createElement("div");

  divResults.innerHTML = s;

  document.getElementById("divResults").appendChild(divResults);

​

}

const getDebug = (name:string) => {

  return [

    (x: any) => debug("<div style='color:blue'>** NEXT: " + name + " = " + x + "</div>"), 

    (e: Error) => debug("<div style='color:red'>** ERROR: " + name + " = " + e.message + "</div>"), 

    () => debug("<div style='color:green'>** COMPLETE: " + name  + "</div>")

  ];

};

test2();

​