Skip to main content
Version: v1

MockDeltaManager Class

Mock implementation of IDeltaManager for testing that creates mock DeltaQueues for testing

Signature

export declare class MockDeltaManager extends TypedEventEmitter<IDeltaManagerEvents> implements IDeltaManager<ISequencedDocumentMessage, IDocumentMessage>

Extends: TypedEventEmitter<IDeltaManagerEvents

Implements: IDeltaManager<ISequencedDocumentMessage, IDocumentMessage

Constructors

Constructor Description
(constructor)() Constructs a new instance of the MockDeltaManager class

Properties

Property Type Description
active boolean
clientDetails IClientDetails
clientType string
disposed any
hasCheckpointSequenceNumber boolean
IDeltaSender this
inbound MockDeltaQueue<ISequencedDocumentMessage>
inboundSignal MockDeltaQueue<ISignalMessage>
initialSequenceNumber number
lastKnownSeqNumber
lastMessage ISequencedDocumentMessage | undefined
lastSequenceNumber number
maxMessageSize number
minimumSequenceNumber number
outbound MockDeltaQueue<IDocumentMessage[]>
readOnlyInfo ReadOnlyInfo
serviceConfiguration IClientConfiguration
version string

Methods

Method Return Type Description
close() void
dispose() void
flush() void
submit(type, contents, batch, localOpMetadata) number
submitSignal(content) void

Constructor Details

(constructor)

Constructs a new instance of the MockDeltaManager class

Signature

constructor();

Property Details

active

Signature

get active(): boolean;

Type: boolean

clientDetails

Signature

readonly clientDetails: IClientDetails;

Type: IClientDetails

clientType

Signature

readonly clientType: string;

Type: string

disposed

Signature

get disposed(): any;

Type: any

hasCheckpointSequenceNumber

Signature

hasCheckpointSequenceNumber: boolean;

Type: boolean

IDeltaSender

Signature

get IDeltaSender(): this;

Type: this

inbound

Signature

get inbound(): MockDeltaQueue<ISequencedDocumentMessage>;

Type: MockDeltaQueue<ISequencedDocumentMessage>

inboundSignal

Signature

get inboundSignal(): MockDeltaQueue<ISignalMessage>;

Type: MockDeltaQueue<ISignalMessage>

initialSequenceNumber

Signature

initialSequenceNumber: number;

Type: number

lastKnownSeqNumber

Signature

readonly lastKnownSeqNumber = 0;

lastMessage

Signature

lastMessage: ISequencedDocumentMessage | undefined;

Type: ISequencedDocumentMessage | undefined

lastSequenceNumber

Signature

lastSequenceNumber: number;

Type: number

maxMessageSize

Signature

get maxMessageSize(): number;

Type: number

minimumSequenceNumber

Signature

minimumSequenceNumber: number;

Type: number

outbound

Signature

get outbound(): MockDeltaQueue<IDocumentMessage[]>;

Type: MockDeltaQueue<IDocumentMessage[]>

readOnlyInfo

Signature

readOnlyInfo: ReadOnlyInfo;

Type: ReadOnlyInfo

serviceConfiguration

Signature

get serviceConfiguration(): IClientConfiguration;

Type: IClientConfiguration

version

Signature

get version(): string;

Type: string

Method Details

close

Signature

close(): void;

dispose

Signature

dispose(): void;

flush

Signature

flush(): void;

submit

Signature

submit(type: MessageType, contents: any, batch: boolean | undefined, localOpMetadata: any): number;

Parameters

Parameter Type Description
type MessageType
contents any
batch boolean | undefined
localOpMetadata any

Returns

Return type: number

submitSignal

Signature

submitSignal(content: any): void;

Parameters

Parameter Type Description
content any