import type { ILiveRTMP } from '../interface/index'; import UpSpeed from './UpSpeed'; /** * responsibility * - 建立http连接、发包 * - 上行速度统计,动态调整编码 * * todo: 断网重连 */ export default class Wtp { _core: ILiveRTMP; _queue: Array; _url: string; _connectClosed: boolean; _upSpeed: UpSpeed; _transport: any; _writer: WritableStreamDefaultWriter | null; _inWriting: boolean; _inAdjustEncode: boolean; _increaseTimer: number; _firstFramePushed: boolean; constructor(core: ILiveRTMP); get sendSpeed(): number; getStats(): any; _bindEvents(): void; _checkDecreaseBitrate(): void; _checkIncreaseBitrate(): void; _checkDeleteCache(key: boolean): void; start(url: string): Promise; _connect(): Promise; _write(): Promise; getFile(): Uint8Array; destroy(): void; }