Options
All
  • Public
  • Public/Protected
  • All
Menu

Class Tunnel<A, B>

see

tunnel for reference & examples.

Type parameters

  • A

  • B

Hierarchy

Index

Constructors

constructor

Properties

Optional __owner

__owner: ISubscription<any, any>

Internal use only. Do not use.

Protected cacheLast

cacheLast: boolean

closeIn

closeIn: CloseMode

closeOut

closeOut: CloseMode

id

id: string

index

index: number

interrupt

interrupt: boolean

Protected last

last: any = ...

Optional parent

parent: ISubscription<any, A>

src

src: string | Worker | Blob

Protected state

state: State = ...

Protected subs

subs: Partial<ISubscriber<B>>[] = ...

terminate

terminate: number

Optional transferables

transferables: Fn<A, any[]>

workers

workers: Worker[]

Protected Optional wrapped

wrapped: Partial<ISubscriber<B>>

Protected Optional xform

xform: Reducer<B[], A>

Methods

deref

  • deref(): undefined | B

Protected dispatch

  • dispatch(x: B): void

Protected dispatchTo

  • dispatchTo(type: "error" | "next" | "done", x?: B): boolean

Protected dispatchXform

  • dispatchXform(x: A): void

Protected dispatchXformDone

  • dispatchXformDone(): boolean

Protected dispatchXformVals

  • dispatchXformVals(acc: B[] | Reduced<B[]>): boolean

done

  • done(): void

Protected ensureState

  • ensureState(): void

error

  • error(e: any): boolean
  • Error handler, which will be called to handle any uncaught errors while executing ISubscriber.next or a transducer function attached to the Subscription wrapping this subscriber. The error handler must return true to indicate the error could be successfully handled/recovered from. If false, the subscription will go into State.ERROR and stops processing any further values (plus might trigger recursive teardown of the upstream dataflow topology).

    Parameters

    • e: any

    Returns boolean

getState

map

next

  • next(x: A): void

Protected release

  • release(): void

Protected setState

  • setState(state: State): void

subscribe

transform

Protected unhandledError

  • unhandledError(e: any): boolean

unsubscribe

Protected unsubscribeChild

Protected unsubscribeSelf

  • unsubscribeSelf(): boolean

Generated using TypeDoc