I hereby claim:
- I am hermanbanken on github.
- I am hermanbanken (https://keybase.io/hermanbanken) on keybase.
- I have a public key ASBjLbD1MTjXXM6g2laBrCbIwdFtH4su3dKPB3cAozB3vgo
To claim this, I am signing this object:
I hereby claim:
To claim this, I am signing this object:
<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/4.1.0/rx.all.min.js"></script> |
<script src="https://cdnjs.cloudflare.com/ajax/libs/underscore.js/1.8.3/underscore-min.js"></script> | |
<script src="https://cdn.rawgit.com/hermanbanken/f1af739c111f2f918406026705f53761/raw/c22eddb2c36c01a51c66740cf674093ba4bf8729/meteor-reactive-packages.js"></script> | |
<script> | |
var energyUse = ReactiveVar(0); | |
var energyAccumulate = ReactiveVar(0); | |
Tracker.autorun(() => { | |
// Do not register dependency on energyAccumulate | |
var prev = Tracker.nonreactive(() => energyAccumulate.get()); | |
// Registering dependency on energyUse | |
energyAccumulate.set(prev + energyUse.get()); |
<script src="https://cdnjs.cloudflare.com/ajax/libs/underscore.js/1.8.3/underscore-min.js"></script> | |
<script src="https://cdn.rawgit.com/hermanbanken/f1af739c111f2f918406026705f53761/raw/c22eddb2c36c01a51c66740cf674093ba4bf8729/meteor-reactive-packages.js"></script> |
/* This file contains 5 core meteor packages | |
* Base64 | |
* EJSON | |
* Tracker (formerly Deps) | |
* ReactiveDict | |
* ReactiveVar | |
* mrt:reactive-object | |
* http://stackoverflow.com/a/26996309/552203 | |
* Copyright: Dean Radcliffe | |
*/ |
'use strict'; | |
var Rx = require("rx") | |
var test = require("qunitjs").test | |
/** stupid RxJS testing code **/ | |
function createMessage(expected, actual) { | |
return ['Expected: [' + expected.toString() + "]", "Actual: [" + actual.toString() + ']']; | |
} |
let observable: Observable<Bool> | |
////////// A | |
return observable.publish(obs => | |
Observable.merge( | |
obs.filter(v => v).doOnNext(":)"), | |
obs.filter(v =>!v).doOnNext(":(") | |
) | |
) |
Adds 6 Observable fields on UIViewController:
Two main Observable<Bool>
And conveniently splitting those two out into Observable<Void>
:
import Rx from 'rx'; | |
// ES6 source, compile with babel | |
// Usage: | |
// import hook from 'rx-debug' | |
// hook() | |
// Then: | |
// Observable.just(1).debug("your tag") | |
// You will observe subscriptions, nexts, error and completion. |