Skip to content

Commit 67edec7

Browse files
committed
Implement Reliable Application Transport
Change-Id: I5797f6b70726ae07cb427f8cab7c5fd2c55c4baa
1 parent 4609f95 commit 67edec7

File tree

6 files changed

+693
-1
lines changed

6 files changed

+693
-1
lines changed

src/Link.test.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,7 @@ import { SocketLike } from './Socket';
77

88
jest.mock('./Interface');
99
jest.mock('./transports/BestEffortTransport');
10+
jest.mock('./transports/ReliableTransport');
1011

1112
let intf: Interface;
1213
let link: Link;

src/Link.ts

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@ import EventEmitter from 'events';
22
import Interface from './Interface';
33
import Transport, {
44
BestEffortTransport,
5+
ReliableTransport,
56
TransportConstructor,
67
} from './transports';
78
import { SocketLike } from './Socket';
@@ -10,6 +11,7 @@ export default class Link extends EventEmitter {
1011
private static availableTransports: { [name: string]: TransportConstructor } =
1112
{
1213
bestEffort: BestEffortTransport,
14+
reliable: ReliableTransport,
1315
};
1416

1517
public closed = false;

src/transports/BestEffortTransport.test.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -112,7 +112,7 @@ it('restarts transport if ping fails', async () => {
112112

113113
expect(ncpRestartSpy).not.toBeCalled();
114114
jest.runAllTimers();
115-
const waitForEventLoopTick = new Promise(resolve => setImmediate(resolve));
115+
const waitForEventLoopTick = new Promise((resolve) => setImmediate(resolve));
116116
jest.runAllTimers();
117117
await waitForEventLoopTick;
118118
expect(ncpRestartSpy).toBeCalled();

0 commit comments

Comments
 (0)