本文整理汇总了TypeScript中rxjs/operator/share.share类的典型用法代码示例。如果您正苦于以下问题:TypeScript share类的具体用法?TypeScript share怎么用?TypeScript share使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
在下文中一共展示了share类的4个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的TypeScript代码示例。
示例1: makeHistory
handler: (action$: O<A<any>>, options: any) => {
const { re }: { re: (action: A<any>) => void; } = options;
const history = makeHistory(historyImpl, (path => {
const data = router(path);
re({ type: routeType, data });
}));
let isStarted = false;
return share.call(
filter.call(
_do.call(
filter.call(
_do.call(
action$,
() => {
if (!isStarted) {
isStarted = true;
history.start();
}
}
),
(action: A<any>): boolean => action.type === goToType
),
({ data: path }: { data: string }) => history.go(path)
),
() => false // remove all
)
);
}
开发者ID:bouzuya,项目名称:boa-handler-history,代码行数:28,代码来源:index.ts
示例2: run
export default function run(app: Handler): void {
const subject = new Subject<A<any>>();
const $ = subject.asObservable();
const filtered$ = filter.call($, action => !!action);
const action$ = share.call(filtered$);
const re = (action: A<any>) => setTimeout(() => subject.next(action));
app(action$, { re }).subscribe(re);
};
开发者ID:bouzuya,项目名称:boa-core,代码行数:8,代码来源:run.ts
示例3: makeRender
const handler = (action$: O<A<any>>, options: any): O<A<any>> => {
const { re } = options;
let start = false;
let renderToHTML = makeRender();
return share.call(
filter.call(
_do.call(
filter.call(
_do.call(
action$,
() => {
if (!start) {
start = true;
const proc = (request: any, response: any) => {
const { route, params } = http(request.path);
re({
type: httpRequestType,
data: { route, params, http: { request, response } }
});
};
setTimeout(() => runServer(dir, middlewares, port, proc), 0);
}
}
),
(action: A<any>): boolean => action.type === httpResponseType
),
({ data: { error, state, http: { response } } }) => {
if (error && error.message === 'redirect') {
const { status, path } = error;
response.redirect(status, path);
} else if (error) {
const { status, path } = error;
response.send(error.message);
} else {
const vtree = render(state, { create, e: (): void => null });
const rendered = renderToHTML(vtree);
const { result: html } = rendered;
renderToHTML = rendered.render;
response.send(html);
}
}
),
() => false
)
);
};
开发者ID:bouzuya,项目名称:boa-handler-init,代码行数:46,代码来源:index.ts
示例4: DOM
const handler: Handler = (action$, options) => {
const { root, render, renderActionType } = domOptions;
const type = renderActionType ? renderActionType : 'render';
const dom = new DOM(root);
const { re } = options;
return share.call(
filter.call(
_do.call(
filter.call(
action$,
(action: A<any>): boolean => action.type === type
),
(action: A<any>): void => {
const state = action.data;
const vtree = render(state, { create, e: re });
dom.renderToDOM(vtree);
}
),
() => false // remove all
)
);
};
开发者ID:bouzuya,项目名称:boa-handler-dom,代码行数:22,代码来源:index.ts
注:本文中的rxjs/operator/share.share类示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论