pure should be applicative pure, from state -> FantasyX

Author: jcouyang

src/__tests__/fantasy-test.tsx

@@ -1,7 +1,7 @@
 import * as React from 'react';
 import { mount } from 'enzyme';
 import '@reactivex/rxjs'
-import { Plan, X, pure, map, lift2, lift, lift3, lift4, lift5, concat } from '..'
+import { Plan, X, fromPlan, map, lift2, lift, lift3, lift4, lift5, concat } from '..'
 import * as rx from '../xs/rx'
 import { Observable } from '@reactivex/rxjs'
 import '@reactivex/rxjs/dist/cjs/add/observable/combineLatest'
@@ -31,7 +31,7 @@ interface CountProps {
 
 let mountx = compose(mount, y => React.createFactory(X)({ x: rx }, y))
 
-const fantasyX = pure<rx.URI, Intent, CountProps>((intent$) => {
+const fantasyX = fromPlan<rx.URI, Intent, CountProps>((intent$) => {
   return {
     update$: intent$.map((intent) => {
       switch (intent.type) {
@@ -153,7 +153,7 @@ describe('actions', () => {
   describe('concat', () => {
     let fantasyXB;
     beforeEach(() => {
-      fantasyXB = pure<rx.URI, Intent, CountProps>((intent$) => {
+      fantasyXB = fromPlan<rx.URI, Intent, CountProps>((intent$) => {
         return {
           update$: intent$.map((intent) => {
             switch (intent.type) {
@@ -244,7 +244,7 @@ describe('liftN', () => {
 
   beforeEach(() => {
     let fan = [1, 2, 3, 4, 5];
-    Fa = fan.map(i => pure<rx.URI, Intent, CountProps>(intent$ => {
+    Fa = fan.map(i => fromPlan<rx.URI, Intent, CountProps>(intent$ => {
       return {
         update$: Observable.of(state => ({ count: i })),
         actions: {

src/fantasy/index.ts

@@ -1,10 +1,10 @@
-import { HKTS, streamOps } from '../xs'
+import { HKTS, streamOps, HKT } from '../xs'
 import { FantasyX } from './fantasyx'
 import { Plan, Update } from '../interfaces'
 import { StateP, Partial } from './interfaces'
 import { State } from './state'
 
-export function pure<E extends HKTS, I, S>(plan: Plan<E, I, S>): FantasyX<E, I, S> {
+export function fromPlan<E extends HKTS, I, S>(plan: Plan<E, I, S>): FantasyX<E, I, S> {
   return new FantasyX<E, I, S>(intent$ => {
     let { update$, actions } = plan(intent$)
     return {
@@ -16,6 +16,14 @@ export function pure<E extends HKTS, I, S>(plan: Plan<E, I, S>): FantasyX<E, I,
   })
 }
 
+export function pure<E extends HKTS, I, S>(s: S) {
+  return new FantasyX<E, I, S>(intent$ => {
+    return {
+      update$: streamOps.map<I, StateP<S>>(() => State.pure<S>(s), intent$ as HKT<I>[E])
+    }
+  })
+}
+
 export function map<E extends HKTS, I, A>(
   f: (s: Partial<A>) => Partial<A>, fa: FantasyX<E, I, A>
 ): FantasyX<E, I, A> {

src/forms/index.ts

@@ -1,5 +1,5 @@
 import { HKTS, streamOps, HKT } from '../xs'
-import { Update, pure } from '..'
+import { Update, fromPlan } from '..'
 import { FantasyX } from '../fantasy/fantasyx'
 import { Partial } from '../fantasy/interfaces'
 
@@ -11,7 +11,7 @@ export function xinput<
   E extends HKTS,
   I extends Event,
   S extends AnyProps>(name: keyof S) {
-  return pure<E, I, S>(intent$ => {
+  return fromPlan<E, I, S>(intent$ => {
     return {
       update$:
       streamOps.map<string, Update<S>>(

src/xs/index.ts

@@ -19,6 +19,7 @@ export interface XStream<F extends HKTS> {
 export class StreamOps<F extends HKTS> { }
 export interface StreamOps<F extends HKTS> {
   empty<A>(): HKT<A>[F]
+  just<A>(a: A): HKT<A>[F]
   merge<A>(
     a: HKT<A>[F],
     b: HKT<A>[F]

src/xs/most.ts

@@ -1,4 +1,4 @@
-import { Stream, empty, combineArray } from 'most'
+import { Stream, empty, just, combineArray } from 'most'
 import { sync, SyncSubject, Subject } from 'most-subject'
 import { Subscription, StreamOps } from './index'
 
@@ -9,6 +9,7 @@ declare module './index' {
 }
 
 StreamOps.prototype.empty = empty
+StreamOps.prototype.just = just
 StreamOps.prototype.merge = function(a, b) {
   return a.merge(b)
 }

src/xs/rx.ts

@@ -16,6 +16,8 @@ declare module './index' {
 
 StreamOps.prototype.empty = Observable.empty
 
+StreamOps.prototype.just = Observable.of
+
 StreamOps.prototype.combine = function(f, ...v) {
   return Observable.combineLatest(v, f)
 }