Options
All
  • Public
  • Public/Protected
  • All
Menu

Interface GenericStreamlet<I, O>

Type parameters

  • I

  • O

Hierarchy

Implemented by

Index

Methods

bindInput

  • bindInput(key: string, input: Outlet<I>): void

didInvalidateInlet

  • didInvalidateInlet(inlet: Inlet<I>): void

didInvalidateOutlet

  • didInvalidateOutlet(outlet: Outlet<O>): void

didReconcileInlet

  • didReconcileInlet(inlet: Inlet<I>, version: number): void

didReconcileOutlet

  • didReconcileOutlet(outlet: Outlet<O>, version: number): void

disconnectInputs

  • disconnectInputs(): void

disconnectOutputs

  • disconnectOutputs(): void

getOutput

  • getOutput(outlet: Outlet<O>): O | undefined

inlet

  • inlet(key: string): Inlet<I> | null

invalidate

  • invalidate(): void
  • Marks this Streamlet—and all of its outlets—as having stale state. Invalidating a Streamlet will recursively invalidate all streamlets that transitively depend on the state of this Streamlet. Invalidating a Streamlet does not cause its state to be recomputed. A subsequent reconcile call will reconcile the state of the Streamlet.

    Returns void

outlet

  • outlet(key: string): Outlet<O> | null

reconcile

  • reconcile(version: number): void
  • Reconciles the state of this Streamlet, if the version of this Streamlet's state differs from the target version. To reconcile its state, the Streamlet first invokes Inlet.reconcileOutput on each of its inlets, to ensure that its input states are up-to-date. It then recomputes its own state, in an implementation defined manner. Finally, it invokes Outlet.reconcileInput on its outlets, causing all transitively dependent streamlets to reconcile their own state.

    Parameters

    • version: number

    Returns void

setStreamletContext

setStreamletScope

streamletContext

streamletScope

unbindInput

  • unbindInput(key: string): void

willInvalidateInlet

  • willInvalidateInlet(inlet: Inlet<I>): void

willInvalidateOutlet

  • willInvalidateOutlet(outlet: Outlet<O>): void

willReconcileInlet

  • willReconcileInlet(inlet: Inlet<I>, version: number): void

willReconcileOutlet

  • willReconcileOutlet(outlet: Outlet<O>, version: number): void