blob: d90e95cf54dc8e518426e4b7daea1b415a4e10f7 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
|
import { MatrixClient } from "./client";
import { ToDeviceBatch } from "./models/ToDeviceMessage";
/**
* Maintains a queue of outgoing to-device messages, sending them
* as soon as the homeserver is reachable.
*/
export declare class ToDeviceMessageQueue {
private client;
private sending;
private running;
private retryTimeout;
private retryAttempts;
constructor(client: MatrixClient);
start(): void;
stop(): void;
queueBatch(batch: ToDeviceBatch): Promise<void>;
sendQueue: () => Promise<void>;
/**
* Attempts to send a batch of to-device messages.
*/
private sendBatch;
/**
* Listen to sync state changes and automatically resend any pending events
* once syncing is resumed
*/
private onResumedSync;
}
//# sourceMappingURL=ToDeviceMessageQueue.d.ts.map
|
