import { Observable } from 'rxjs' ; import { SubscriptionLog } from '../../src/internal/testing/SubscriptionLog' ; import { ColdObservable } from '../../src/internal/testing/ColdObservable' ; import { HotObservable } from '../../src/internal/testing/HotObservable' ; import { observableToBeFn , subscriptionLogsToBeFn } from '../../src/internal/testing/TestScheduler' ; declare const global ; export function hot ( marbles , values ? , error ? ) ; export function hot < V > ( marbles , values ? , error ? ) ; export function hot < V > ( marbles , values ? , error ? ) { if ( ! global . rxTestScheduler ) { throw 'tried to use hot() in async test' ; } return global . rxTestScheduler . createHotObservable . apply ( global . rxTestScheduler , arguments ) ; } export function cold ( marbles , values ? , error ? ) ; export function cold < V > ( marbles , values ? , error ? ) ; export function cold ( marbles , values ? , error ? ) { if ( ! global . rxTestScheduler ) { throw 'tried to use cold() in async test' ; } return global . rxTestScheduler . createColdObservable . apply ( global . rxTestScheduler , arguments ) ; } export function expectObservable ( observable , unsubscriptionMarbles = null ) { if ( ! global . rxTestScheduler ) { throw 'tried to use expectObservable() in async test' ; } return global . rxTestScheduler . expectObservable . apply ( global . rxTestScheduler , arguments ) ; } export function expectSubscriptions ( actualSubscriptionLogs ) { if ( ! global . rxTestScheduler ) { throw 'tried to use expectSubscriptions() in async test' ; } return global . rxTestScheduler . expectSubscriptions . apply ( global . rxTestScheduler , arguments ) ; } export function time ( marbles ) { if ( ! global . rxTestScheduler ) { throw 'tried to use time() in async test' ; } return global . rxTestScheduler . createTime . apply ( global . rxTestScheduler , arguments ) ; }