Interface ObservableStream

Hierarchy

Properties

_isScalar: boolean

Internal implementation detail, do not use directly.

operator: Operator<any, ChannelMessage>

Deprecated

This is an internal implementation detail, do not use.

source: Observable<any>

Deprecated

This is an internal implementation detail, do not use.

Methods

  • Internal

    This is an internal implementation detail, do not use.

    Parameters

    • subscriber: Subscriber<any>

    Returns TeardownLogic

  • Deprecated

    This is an internal implementation detail, do not use.

    Parameters

    Returns TeardownLogic

  • Method

    forEach

    Returns

    a promise that either resolves on observable completion or rejects with the handled error

    Parameters

    • next: ((value: ChannelMessage) => void)

      a handler for each value emitted by the observable

    • Optional promiseCtor: PromiseConstructorLike

      a constructor function used to instantiate the Promise

    Returns Promise<void>

  • Creates a new Observable, with this Observable as the source, and the passed operator defined as the new observable's operator.

    Method

    lift

    Returns

    a new observable with the Operator applied

    Type Parameters

    • R

    Parameters

    • operator: Operator<ChannelMessage, R>

      the operator defining the operation to take on the observable

    Returns Observable<R>

  • Returns Observable<ChannelMessage>

  • Type Parameters

    • A

    Parameters

    Returns Observable<A>

  • Type Parameters

    • A

    • B

    Parameters

    Returns Observable<B>

  • Type Parameters

    • A

    • B

    • C

    Parameters

    • op1: OperatorFunction<ChannelMessage, A>
    • op2: OperatorFunction<A, B>
    • op3: OperatorFunction<B, C>

    Returns Observable<C>

  • Type Parameters

    • A

    • B

    • C

    • D

    Parameters

    • op1: OperatorFunction<ChannelMessage, A>
    • op2: OperatorFunction<A, B>
    • op3: OperatorFunction<B, C>
    • op4: OperatorFunction<C, D>

    Returns Observable<D>

  • Type Parameters

    • A

    • B

    • C

    • D

    • E

    Parameters

    • op1: OperatorFunction<ChannelMessage, A>
    • op2: OperatorFunction<A, B>
    • op3: OperatorFunction<B, C>
    • op4: OperatorFunction<C, D>
    • op5: OperatorFunction<D, E>

    Returns Observable<E>

  • Type Parameters

    • A

    • B

    • C

    • D

    • E

    • F

    Parameters

    • op1: OperatorFunction<ChannelMessage, A>
    • op2: OperatorFunction<A, B>
    • op3: OperatorFunction<B, C>
    • op4: OperatorFunction<C, D>
    • op5: OperatorFunction<D, E>
    • op6: OperatorFunction<E, F>

    Returns Observable<F>

  • Type Parameters

    • A

    • B

    • C

    • D

    • E

    • F

    • G

    Parameters

    • op1: OperatorFunction<ChannelMessage, A>
    • op2: OperatorFunction<A, B>
    • op3: OperatorFunction<B, C>
    • op4: OperatorFunction<C, D>
    • op5: OperatorFunction<D, E>
    • op6: OperatorFunction<E, F>
    • op7: OperatorFunction<F, G>

    Returns Observable<G>

  • Type Parameters

    • A

    • B

    • C

    • D

    • E

    • F

    • G

    • H

    Parameters

    • op1: OperatorFunction<ChannelMessage, A>
    • op2: OperatorFunction<A, B>
    • op3: OperatorFunction<B, C>
    • op4: OperatorFunction<C, D>
    • op5: OperatorFunction<D, E>
    • op6: OperatorFunction<E, F>
    • op7: OperatorFunction<F, G>
    • op8: OperatorFunction<G, H>

    Returns Observable<H>

  • Type Parameters

    • A

    • B

    • C

    • D

    • E

    • F

    • G

    • H

    • I

    Parameters

    • op1: OperatorFunction<ChannelMessage, A>
    • op2: OperatorFunction<A, B>
    • op3: OperatorFunction<B, C>
    • op4: OperatorFunction<C, D>
    • op5: OperatorFunction<D, E>
    • op6: OperatorFunction<E, F>
    • op7: OperatorFunction<F, G>
    • op8: OperatorFunction<G, H>
    • op9: OperatorFunction<H, I>

    Returns Observable<I>

  • Type Parameters

    • A

    • B

    • C

    • D

    • E

    • F

    • G

    • H

    • I

    Parameters

    • op1: OperatorFunction<ChannelMessage, A>
    • op2: OperatorFunction<A, B>
    • op3: OperatorFunction<B, C>
    • op4: OperatorFunction<C, D>
    • op5: OperatorFunction<D, E>
    • op6: OperatorFunction<E, F>
    • op7: OperatorFunction<F, G>
    • op8: OperatorFunction<G, H>
    • op9: OperatorFunction<H, I>
    • Rest ...operations: OperatorFunction<any, any>[]

    Returns Observable<{}>

  • Sends a message through the websocket channel

    Parameters

    • message: JsonMap

      The message to send

    Returns void

  • Parameters

    Returns Subscription

  • Deprecated

    Use an observer instead of a complete callback

    Parameters

    • next: undefined | null
    • error: undefined | null
    • complete: (() => void)
        • (): void
        • Returns void

    Returns Subscription

  • Deprecated

    Use an observer instead of an error callback

    Parameters

    • next: undefined | null
    • error: ((error: any) => void)
        • (error: any): void
        • Parameters

          • error: any

          Returns void

    • Optional complete: (() => void)
        • (): void
        • Returns void

    Returns Subscription

  • Deprecated

    Use an observer instead of a complete callback

    Parameters

    Returns Subscription

  • Parameters

    • Optional next: ((value: ChannelMessage) => void)
    • Optional error: ((error: any) => void)
        • (error: any): void
        • Parameters

          • error: any

          Returns void

    • Optional complete: (() => void)
        • (): void
        • Returns void

    Returns Subscription

  • Type Parameters

    • T

    Parameters

    • this: Observable<T>

    Returns Promise<T>

  • Type Parameters

    • T

    Parameters

    • this: Observable<T>
    • PromiseCtor: PromiseConstructor

    Returns Promise<T>

  • Type Parameters

    • T

    Parameters

    • this: Observable<T>
    • PromiseCtor: PromiseConstructorLike

    Returns Promise<T>

Generated using TypeDoc