Skip to content

Commit 86c8a26

Browse files
improve name
1 parent db6c98a commit 86c8a26

File tree

3 files changed

+4
-4
lines changed

3 files changed

+4
-4
lines changed

src/channel/channel.registry.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ export class ChannelRegistry {
3131
return this.registry.get(name);
3232
}
3333

34-
getALl(): Channel<any>[] {
34+
getAll(): Channel<any>[] {
3535
return Array.from(this.registry.values());
3636
}
3737
}

src/consumer/distributed.consumer.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ export class DistributedConsumer {
3131
}
3232

3333
async run(): Promise<void> {
34-
for (const channel of this.channelRegistry.getALl()) {
34+
for (const channel of this.channelRegistry.getAll()) {
3535
if (
3636
channel instanceof InMemoryChannel ||
3737
false === channel.config.enableConsumer

test/unit/channel/channel.registry.spec.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ describe('ChannelRegistry', () => {
2222

2323
test('should not register the same channel twice', () => {
2424
registry.register(mockChannel);
25-
expect(registry.getALl().length).toBe(1);
25+
expect(registry.getAll().length).toBe(1);
2626
});
2727

2828
test('should throw an exception if no channel is found by name', () => {
@@ -32,6 +32,6 @@ describe('ChannelRegistry', () => {
3232
test('should retrieve all registered channels', () => {
3333
const anotherMockChannel = { config: { name: 'anotherChannel' } } as unknown as Channel<any>;
3434
registry.register(anotherMockChannel);
35-
expect(registry.getALl()).toEqual([mockChannel, anotherMockChannel]);
35+
expect(registry.getAll()).toEqual([mockChannel, anotherMockChannel]);
3636
});
3737
});

0 commit comments

Comments
 (0)