MCPcopy Index your code
hub / github.com/deepstreamIO/deepstream.io / writeAckError

Function writeAckError

test-e2e/framework/record.ts:110–123  ·  view source on GitHub ↗
(clientExpression: string, recordName: string, errorMessage: string)

Source from the content-addressed store, hash-verified

108 },
109
110 writeAckError (clientExpression: string, recordName: string, errorMessage: string) {
111 getRecordData(clientExpression, recordName).forEach((recordData) => {
112 if (!recordData) { return }
113 sinon.assert.calledOnce(recordData.setCallback)
114 sinon.assert.calledWith(recordData.setCallback, errorMessage)
115 recordData.setCallback.resetHistory()
116 })
117 clientHandler.getClients(clientExpression).forEach((client) => {
118 if (!client.record.writeAcks) { return }
119 sinon.assert.calledOnce(client.record.writeAcks[recordName])
120 sinon.assert.calledWith(client.record.writeAcks[recordName], errorMessage)
121 client.record.writeAcks[recordName].resetHistory()
122 })
123 },
124
125 snapshotSuccess (clientExpression: string, recordName: string, data: string) {
126 clientHandler.getClients(clientExpression).forEach((client) => {

Callers

nothing calls this directly

Calls 2

forEachMethod · 0.80
getRecordDataFunction · 0.70

Tested by

no test coverage detected