MCPcopy
hub / github.com/deepstreamIO/deepstream.io / writeAckSuccess

Function writeAckSuccess

test-e2e/framework-v3/record.ts:98–111  ·  view source on GitHub ↗
(clientExpression: string, recordName: string)

Source from the content-addressed store, hash-verified

96 },
97
98 writeAckSuccess (clientExpression: string, recordName: string) {
99 getRecordData(clientExpression, recordName).forEach((recordData) => {
100 if (!recordData) { return }
101 sinon.assert.calledOnce(recordData.setCallback)
102 sinon.assert.calledWith(recordData.setCallback, null)
103 recordData.setCallback.resetHistory()
104 })
105 clientHandler.getClients(clientExpression).forEach((client) => {
106 if (!client.record.writeAcks) { return }
107 sinon.assert.calledOnce(client.record.writeAcks[recordName])
108 sinon.assert.calledWith(client.record.writeAcks[recordName], null)
109 client.record.writeAcks[recordName].resetHistory()
110 })
111 },
112
113 writeAckError (clientExpression: string, recordName: string, errorMessage: string) {
114 cl.receivedOneError(clientExpression, 'RECORD', errorMessage)

Callers

nothing calls this directly

Calls 2

forEachMethod · 0.80
getRecordDataFunction · 0.70

Tested by

no test coverage detected