Options
All
  • Public
  • Public/Protected
  • All
Menu

Class PendingSetStream

An update stream delegate that is used when a set operation is called on a new stream. The server has not yet responded to the initial set operation.

Hierarchy

  • PendingSetStream

Implements

  • any

Index

Constructors

Properties

Methods

Constructors

constructor

  • Create a new PendingSetStream instance

    Parameters

    • streamServices: StreamServices

      the stream services

    • options: UpdateStreamOptions

      the update stream options

    • stream: UpdateStreamImpl

      the stream that using this stream as a delegate

    • pendingResult: Result<any>

      the pending result

    • value: any

      the value of the pending set operation

    Returns PendingSetStream

Properties

Private deferredResolvers

deferredResolvers: DeferredResolution[]

Any deferred emitters that should be emitted once the pending result completes

Private nextValue

nextValue: any

The cached value of any subsequent set operations

Private options

options: UpdateStreamOptions

The update stream options

Private pendingResult

pendingResult: Result<any>

The pending result

Private stream

stream: UpdateStreamImpl

The stream that wrapped around this stream and using is as a delegate

Private streamServices

streamServices: StreamServices

The stream services

Private value

value: any

The value of the pending set operation

Methods

get

  • get(): any
  • inheritdoc

    Returns any

onSetComplete

  • onSetComplete(streamId: UpdateStreamId, retainsValue: boolean, supportsConflation: boolean): void
  • inheritdoc

    Parameters

    • streamId: UpdateStreamId
    • retainsValue: boolean
    • supportsConflation: boolean

    Returns void

onSetFailed

  • onSetFailed(err: Error): void
  • inheritdoc

    Parameters

    • err: Error

    Returns void

onValidateComplete

  • onValidateComplete(): void
  • inheritdoc

    Returns void

onValidateFailed

  • onValidateFailed(): void
  • inheritdoc

    Returns void

Private processPendingUpdatesDoesntRetainValue

  • processPendingUpdatesDoesntRetainValue(streamId: UpdateStreamId): void

  • Parameters

    Returns void

Private processPendingUpdatesRetainsValue

  • Parameters

    Returns void

set

  • set(value: any): Result<void>
  • inheritdoc

    Parameters

    • value: any

    Returns Result<void>

validate