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); | ||
|  | } |