Sawtaytoes

const connectToServerEpic = (
  action$,
) => (
  action$
  .pipe(
    ofType(CONNECT_TO_SERVER),
    switchMap(({
      hostname,
      port,
      protocol,

Sawtaytoes

const connectToWebSocketServiceEpic = (
  action$,
) => (
  action$
  .pipe(
    ofType(APP_STARTED),
    map(
      connectToServer({
        hostname: 'example.com',
        port: 3000,

Sawtaytoes

connectToServer({
  hostname: 'example.com',
  port: 3000,
  protocol: 'ws',
  protocolVersion: 'v1',
})

Sawtaytoes

startWith(
  setLoading(
    'login',
  ),
  userState({
    state: userStates.PENDING,
    username,
  }),
)

Sawtaytoes

const fetchUserEpic = (
  action$,
) => (
  action$
  .pipe(
    ofType(FETCH_USER),
    switchMap(({
      password,
      username,
    }) => (

Sawtaytoes

const fetchUserEpic = (
  action$,
  state$,
  { dispatch },
) => (
  action$
  .pipe(
    ofType(FETCH_USER),
    tap(() => {
      dispatch(

Sawtaytoes

const fetchUserEpic = (
  action$,
) => (
  action$
  .pipe(
    ofType(FETCH_USER),
    switchMap(({
      password,
      username,
    }) => (

Sawtaytoes

function instance($$self, $$props, $$invalidate) {
  let count = 0

  const stateModifiers = {
    DECREMENT: () => {
      $$invalidate('count', count -= 1)
    },
    INCREMENT: () => {
      $$invalidate('count', count += 1)
    },

Sawtaytoes

const epic$ = (
  new BehaviorSubject(
    rootEpic
    .pipe(
      switchMap((
        value,
      ) => (
        typeof value === 'object'
        && value.type
        ? of(value)

Sawtaytoes

const someEpic = ({
  action$,
  dispatch,
}) => (
  // ...
)