jayphelps

function isObject(value) {
  // Avoid an old bug in Chrome 19-20
  // See https://code.google.com/p/v8/issues/detail?id=2291
  const type = typeof value;
  return type === 'function' || (!!value && type === 'object');
}

function ofPropertyChanges(obj, key) {
  if (isObject(obj) === false) {
    return Rx.Observable.return(undefined);

jayphelps

function isValidEmail(str) {
  /**
   * These comments use the following terms from RFC2822:
   * local-part, domain, domain-literal and dot-atom.
   * Does the address contain a local-part followed an @ followed by a domain?
   * Note the use of lastIndexOf to find the last @ in the address
   * since a valid email address may have a quoted @ in the local-part.
   * Does the domain name have at least two parts, i.e. at least one dot,
   * after the @? If not, is it a domain-literal?
   * 

jayphelps

window.onclick = () => {
  // You MUST create the window on the same event
  // tick/stack as the user-initiated event (e.g. click callback)
  const googleWindow = window.open();

  // Do your async work
  fakeAjax(response => {
    // Change the URL of the window you created once you
    // know what the full URL is!
    googleWindow.location.replace(`https://google.com?q=${response}`);

jayphelps

const oauthUserEpic = (action$) =>
  action$
    .ofType(OAUTH_USER)
    .concatMap(({ token }) =>
      get({
        endpoint: 'user',
        params: { access_token: token }
      }) // assuming get() returns an Observable
      .map((user) =>
        addUser(

jayphelps

/**
 * README FIRST::::::::::::::::::
 * 
 * This isn't meant to necessarily be an example of "best practices"
 * but rather to generally show how you might convert the redux-thunk examples
 * here: https://gist.github.com/markerikson/ea4d0a6ce56ee479fe8b356e099f857e
 * 
 * The redux-thunk examples used generic placeholder names, so it's possible
 * I misunderstood the usecase/intent.
 * 

jayphelps

// The classic AJAX call - dispatch before the request, and after it comes back
function myThunkActionCreator(someValue) {
    return (dispatch, getState) => {
        dispatch({type : "REQUEST_STARTED"});
        
        myAjaxLib.post("/someEndpoint", {data : someValue})
            .then(response => dispatch({type : "REQUEST_SUCCEEDED", payload : response})
            .catch(error => dispatch({type : "REQUEST_FAILED", error : error});    
    };
}

jayphelps

import { webSocket } from 'rxjs/observable/dom/webSocket';
import { timer } from 'rxjs/observable/timer';
import { fromEvent } from 'rxjs/observable/fromEvent';

// Lazy, doesn't connect when no one is subscribed,
// but to multiplex we need a single static instance
// so that they all use the same socket
const socket$ = webSocket('ws://stock/endpoint');

// So this is bi-direction multiplexing; multiple concurrent

jayphelps

// api.js
// your API call helpers
import { ajax } from 'rxjs/observable/dom/ajax';

export const fetchSomething = id =>
  ajax.getJSON(`/somethings/${id}`);

// the epic

jayphelps

let buffer = getWebSocket()
  .bufferTime(1000);

let gate = new BehaviorSubject(true);
let batchSize = 50;
let batchSizeCounter = 0;

let results = gate
  .switchMap(enabled => enabled ? buffer : Observable.never())
  .do(buffer => {

jayphelps

{
  "scripts": {
    "build": "npm run build:es2015 && npm run build:esm && npm run build:cjs && npm run build:umd && npm run build:umd:min",
    "build:es2015": "tsc --module es2015 --target es2015 --outDir dist/es2015",
    "build:esm": "tsc --module es2015 --target es5 --outDir dist/esm",
    "build:cjs": "tsc --module commonjs --target es5 --outDir dist/cjs",
    "build:umd": "rollup dist/esm/index.js --format umd --name YourLibrary --sourceMap --output dist/umd/yourlibrary.js",
    "build:umd:min": "cd dist/umd && uglifyjs --compress --mangle --source-map --screw-ie8 --comments --o yourlibrary.min.js -- yourlibrary.js && gzip yourlibrary.min.js -c > yourlibrary.min.js.gz",
  }
}