MCPcopy
hub / github.com/nestjs/nest / client-kafka.spec.ts

File client-kafka.spec.ts

packages/microservices/test/client/client-kafka.spec.ts:None–None  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

1import { expect } from 'chai';
2import { Producer } from 'kafkajs';
3import { Observable } from 'rxjs';
4import * as sinon from 'sinon';

Callers

nothing calls this directly

Calls 15

waitForNextTickFunction · 0.85
assignMethod · 0.80
consumerMethod · 0.80
bindTopicsMethod · 0.80
emitBatchMethod · 0.80
subscribeMethod · 0.80
getConsumerAssignmentsMethod · 0.80
hasMethod · 0.80
subscribeToResponseOfMethod · 0.65
closeMethod · 0.65
resolveMethod · 0.65
setMethod · 0.65

Tested by

no test coverage detected