.github
api-server
common
public
server
boot
manifests
middlewares
models
resources
rss
services
utils
about.js
auth.js
bad-id-map.js
cast-to-observable.js
certTypes.json
commit-goals.json
commit.js
commit.json
constantStrings.json
constants.js
create-handled-error.js
date-utils.js
date-utils.test.js
getDynamicPropsForUser.js
index.js
lang-passthrough-urls.js
map.js
middleware.js
publicUserProps.js
react.js
resources.json
rx.js
superBlockCertTypeMap.js
url-utils.js
user-stats.js
user-stats.test.js
views
README.md
component-passport.js
config.development.js
config.json
config.local.js
config.production.js
datasources.development.js
datasources.json
datasources.production.js
debug-entry.js
middleware.json
model-config.json
passport-providers.js
production-start.js
server.js
.babelrc.js
.gitignore
development-entry.js
package-lock.json
package.json
pm2Start.js
post-seed.js
client
config
curriculum
docs
news
tools
.editorconfig
.eslintignore
.eslintrc
.gitattributes
.gitignore
.node-inspectorrc
.prettierrc
.snyk
.travis.yml
.vcmrc
CODE_OF_CONDUCT.md
CONTRIBUTING.md
LICENSE.md
README.md
docker-compose-shared.yml
docker-compose.yml
lerna.json
netlify.toml
package-lock.json
package.json
sample.env
12 lines
268 B
JavaScript
12 lines
268 B
JavaScript
![]() |
import { Observable, helpers } from 'rx';
|
||
|
|
||
|
export default function castToObservable(maybe) {
|
||
|
if (Observable.isObservable(maybe)) {
|
||
|
return maybe;
|
||
|
}
|
||
|
if (helpers.isPromise(maybe)) {
|
||
|
return Observable.fromPromise(maybe);
|
||
|
}
|
||
|
return Observable.of(maybe);
|
||
|
}
|