import type { Observable , OperatorFunction , Subscribable } from 'rxjs' ; import type { StreamState , StreamStateHolder } from './stream' ; /**
 * `pipe` aspect of rxjs Observable.
 */ export interface Pipeable < T > { pipe ( ) : Observable < T > ; pipe < A > ( op1 ) : Observable < A > ; pipe < A , B > ( op1 , op2 ) : Observable < B > ; pipe < A , B , C > ( op1 , op2 , op3 ) : Observable < C > ; pipe < A , B , C , D > ( op1 , op2 , op3 , op4 ) : Observable < D > ; pipe < A , B , C , D , E > ( op1 , op2 , op3 , op4 , op5 ) : Observable < E > ; pipe < A , B , C , D , E , F > ( op1 , op2 , op3 , op4 , op5 , op6 ) : Observable < F > ; pipe < A , B , C , D , E , F , G > ( op1 , op2 , op3 , op4 , op5 , op6 , op7 ) : Observable < G > ; pipe < A , B , C , D , E , F , G , H > ( op1 , op2 , op3 , op4 , op5 , op6 , op7 , op8 ) : Observable < H > ; pipe < A , B , C , D , E , F , G , H , I > ( op1 , op2 , op3 , op4 , op5 , op6 , op7 , op8 , op9 ) : Observable < I > ; pipe < A , B , C , D , E , F , G , H , I > ( op1 , op2 , op3 , op4 , op5 , op6 , op7 , op8 , op9 , ... operations ) : Observable < any > ; } export interface RunningStateLike extends StreamStateHolder , Subscribable < StreamState > , Pipeable < StreamState > { value : StreamState ; next ( value ) : void ; }