type d files

Author: jcouyang

types/engine/most.d.ts

@@ -0,0 +1,9 @@
+import { Stream, Subscription } from 'most';
+import { EngineSubject, Update } from '../interfaces';
+export declare class Engine<T, S> {
+    intentStream: EngineSubject<T>;
+    historyStream: EngineSubject<S>;
+    travelStream: EngineSubject<(n: number) => number>;
+    constructor();
+    observe<T>(actionsSinks: Stream<Update<T>>, f: any): Subscription<T>;
+}

types/history.d.ts

@@ -0,0 +1,12 @@
+import { Stream } from 'most';
+import { Stamp, EngineSubject } from './interfaces';
+export declare class Traveler<S> {
+    cursor: number;
+    path: EngineSubject<(n: number) => number>;
+    history: Stream<Stamp<S>[]>;
+    travel: Stream<S>;
+    constructor(history: Stream<Stamp<S>[]>, path: EngineSubject<(n: number) => number>);
+    forward(): void;
+    backward(): void;
+}
+export default function initHistory<S>(engineHistory: EngineSubject<S>, engineTravel: EngineSubject<(n: number) => number>): Traveler<S>;

types/interfaces.d.ts

@@ -0,0 +1,43 @@
+/// <reference types="react" />
+import { Stream, Subscription } from 'most';
+import * as React from 'react';
+import { AsyncSubject } from 'most-subject';
+import { Traveler } from './history';
+export interface Actions<T> {
+    [propName: string]: (...v: any[]) => T;
+}
+export interface Plan<I, S> {
+    (intent: EngineSubject<I>, props?: {}): Machine<I, S>;
+}
+export interface Update<S> {
+    (current: S): S;
+}
+export interface Machine<I, S> {
+    actions: Actions<I>;
+    update$: Stream<Update<S>>;
+}
+export interface ConnectProps<I> {
+    actions?: Actions<I>;
+    history?: boolean;
+}
+export declare class Connect<I, S> extends React.PureComponent<ConnectProps<I>, S> {
+    machine: Machine<I, S>;
+    traveler: Traveler<S>;
+    subscription: Subscription<S>;
+}
+export interface ConnectClass<I, S> {
+    contextTypes?: any;
+    defaultProps?: any;
+    new (props?: ConnectProps<I>, context?: any): Connect<I, S>;
+}
+export interface History<S> {
+    path: EngineSubject<(n: number) => number>;
+    history: Stream<S>;
+}
+export interface Stamp<S> {
+    value: S;
+    time: number;
+}
+export interface EngineSubject<T> extends AsyncSubject<T> {
+    send(x: T): this;
+}

types/react-most.d.ts

@@ -0,0 +1,22 @@
+/// <reference types="react" />
+import * as React from 'react';
+import { Plan, ConnectClass } from './interfaces';
+import { Engine } from './engine/most';
+export declare const REACT_MOST_ENGINE = "@@reactive-react/react-most.engine";
+export declare type ConnectOrReactComponent<I, S> = ConnectClass<I, S> | React.ComponentClass<any>;
+export declare function connect<I, S>(main: Plan<I, S>, opts?: {
+    history: boolean;
+}): (WrappedComponent: ConnectOrReactComponent<I, S>) => ConnectClass<I, S>;
+export interface MostProps<T, S> {
+    engine?: new () => Engine<T, S>;
+}
+export interface MostEngine<I, H> {
+    [x: string]: Engine<I, H>;
+}
+export default class Most<I, H, S> extends React.PureComponent<MostProps<I, H>, S> {
+    static childContextTypes: {
+        [x: string]: any;
+    };
+    getChildContext(): MostEngine<I, H>;
+    render(): React.ReactElement<any>;
+}