gnezim
27 lines
1010 B
TypeScript
27 lines
1010 B
TypeScript
import { IConnection } from "./IConnection";
|
|
import { AckMessage, HubMessage, IHubProtocol, SequenceMessage } from "./IHubProtocol";
|
|
/** @private */
|
|
export declare class MessageBuffer {
|
|
private readonly _protocol;
|
|
private readonly _connection;
|
|
private readonly _bufferSize;
|
|
private _messages;
|
|
private _totalMessageCount;
|
|
private _waitForSequenceMessage;
|
|
private _nextReceivingSequenceId;
|
|
private _latestReceivedSequenceId;
|
|
private _bufferedByteCount;
|
|
private _reconnectInProgress;
|
|
private _ackTimerHandle?;
|
|
constructor(protocol: IHubProtocol, connection: IConnection, bufferSize: number);
|
|
_send(message: HubMessage): Promise<void>;
|
|
_ack(ackMessage: AckMessage): void;
|
|
_shouldProcessMessage(message: HubMessage): boolean;
|
|
_resetSequence(message: SequenceMessage): void;
|
|
_disconnected(): void;
|
|
_resend(): Promise<void>;
|
|
_dispose(error?: Error): void;
|
|
private _isInvocationMessage;
|
|
private _ackTimer;
|
|
}
|