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

ConstructorDescription
(constructor)()Constructs a new instance of the MockDeltaManager class

Properties

PropertyTypeDescription
activeboolean
clientDetailsIClientDetails
clientTypestring
disposedany
hasCheckpointSequenceNumberboolean
IDeltaSenderthis
inboundMockDeltaQueue<ISequencedDocumentMessage>
inboundSignalMockDeltaQueue<ISignalMessage>
initialSequenceNumbernumber
lastKnownSeqNumber
lastMessageISequencedDocumentMessage | undefined
lastSequenceNumbernumber
maxMessageSizenumber
minimumSequenceNumbernumber
outboundMockDeltaQueue<IDocumentMessage[]>
readOnlyInfoReadOnlyInfo
serviceConfigurationIClientConfiguration
versionstring

Methods

MethodReturn TypeDescription
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

ParameterTypeDescription
typeMessageType
contentsany
batchboolean | undefined
localOpMetadataany

Returns

Return type: number

submitSignal

Signature

submitSignal(content: any): void;

Parameters

ParameterTypeDescription
contentany