BerkeleyTrue

export class BadFunComp extends React.PureComponent {
  handleFun() {
    const { funApi } = this.props;
    funAPi();
  }
  render() {
    // displayCoolness.props.handleFun will always have a new ref value
    // causes child to re-render on ever BadFunComp render
    return (
      <DisplayCoolness onFun={ () => this.handleFun() } />

BerkeleyTrue

const serviceValues = [ 2, 3, 4 ];
// convert values array into a stream of individual values: Obs[...num]
return Observable.of(serviceValues)
  // call service on each value and get Observable in return: Obs[Obs[newValFromService]]
  .map(val => serviceApi(val))
  // convert stream of observables into a stream of a single array of observables Obs[ [Obs[newVal]] ]
  .toArray()
  // trigger all the service calls with maximum concurrenct
  .switchMap((serviceCalls) => Observable.combineLatest(serviceCalls))
  .subscribe(newVals => console.log('new values from server: ', newVals)) // [...{id: 2, ...data}, {id: 3, ...dat}]

BerkeleyTrue

import { createServer, at } from 'fyfe';
import { GET, composeRoutes, composeMiddleware } from 'fyfe-compose-routes';
import fyfeDefaults from 'fyfe-defaults';

// composes routes together
// first route to return something other then Void will win
const routes = composeRoutes(
  // use a route handler
  // Request => Responce|String|Stream|Void
  GET('/', renderIndex),

BerkeleyTrue

function thunkToObservable(thunk) {
  return (getState, ...args) => {
    return new Observable(observer => {
      const dispatchProxy = new Subject();
      const dispatch = action => dispatchProxy.next(action);
      thunk(...args)(dispatch, getState);
      return dispatchProxy.subscribe(observer);
    });
  };
}

BerkeleyTrue

import { ActionsObservable } from 'redux-observale/lib/ActionsObservable';

import rootEpic from './epics';
const flux = new Reactor({ /*...*/ });


const input$ = new Subject();
const actions$ = new ActionsObservable(input$);
const epic$ = new Subject();
 epic$

BerkeleyTrue

import createTypes from 'redux-create-types';

export const ns = 'app';
export const types = createTypes(
  [
    'openModal',
    'onClick',
    'updateEmailSettings',
    createAsyncTypes('fetch')
  ],

BerkeleyTrue

import { Observable } from 'rxjs';

export default function logOutEpic(actions, { getState }) {
  return Observable
    .interval(500)
    .takeUntil(actions.ofType('LOG_OUT').first())
    .map(() => {
      const { app: { accessToken } = {} } = getState();
      return accessToken;
    })

BerkeleyTrue

export function serializeForm(form) {
  const data = [].filter.call(form.elements, node => !!node.name)
    .reduce((data, node) => {
      data[node.name] = node.value;
      return data;
    }, {});

  return JSON.stringify(data);
}

BerkeleyTrue

function(cb) {
  $.ajax()
    .then(() => {
      // do test
      cb();
    });
}

BerkeleyTrue

const logoutTime = 15* 60;
const warningTime = 14 * 60;
function createLogoutActionStream() {
  return Observable.merge(
    Observable.of({ type: 'showLogoutMessageWarning' }).delay(warningTime * 1000),
    Observable.of({ type: 'logOut' }).delay(logoutTIme * 1000)
  );
}

mouseEventStream