import type { EnhancedEventEmitter } from './enhancedEvents'; import type { Transport, TransportListenInfo, TransportListenIp, TransportTuple, SctpState, BaseTransportDump, BaseTransportStats, TransportEvents, TransportObserverEvents } from './TransportTypes'; import type { Consumer } from './ConsumerTypes'; import type { SrtpParameters } from './srtpParametersTypes'; import type { SctpParameters, SctpNegotiatedCapabilities } from './sctpParametersTypes'; import type { Either, AppData } from './types'; export type PipeTransportOptions = { /** * Create a SCTP association. Default false. */ enableSctp?: boolean; /** * Maximum allowed size for SCTP messages sent by DataConsumers (in bytes). * Default 262144. */ maxSendMessageSize?: number; /** * Maximum allowed size for SCTP messages received by DataProducers (in bytes). * Default 262144. */ maxReceiveMessageSize?: number; /** * Maximum SCTP send buffer used by DataConsumers (in bytes). * Default 2000000. */ sctpSendBufferSize?: number; /** * Per stream send queue size limit. Similar to `sctpSendBufferSize`, but * limiting the size of individual streams. * Default 2000000. */ sctpPerStreamSendQueueLimit?: number; /** * Maximum received window buffer size (in bytes). This should be a bit larger * than the largest sized message you want to be able to receive. * Default 5242880. */ sctpMaxReceiverWindowBufferSize?: number; /** * SCTP default stream buffered amount low threshold (in bytes). When the * buffered amount of a DataConsumer stream drops to or below this value, the * 'bufferedamountlow' event is emitted. It can be overridden per DataConsumer * via `dataConsumer.setBufferedAmountLowThreshold()`. * Default 1024. */ sctpDefaultStreamBufferedAmountLowThreshold?: number; /** * Enable RTX and NACK for RTP retransmission. Useful if both Routers are * located in different hosts and there is packet lost in the link. For this * to work, both PipeTransports must enable this setting. Default false. */ enableRtx?: boolean; /** * Enable SRTP. Useful to protect the RTP and RTCP traffic if both Routers * are located in different hosts. For this to work, connect() must be called * with remote SRTP parameters. Default false. */ enableSrtp?: boolean; /** * Custom application data. */ appData?: PipeTransportAppData; } & PipeTransportListen; type PipeTransportListen = Either; type PipeTransportListenInfo = { /** * Listening info. */ listenInfo: TransportListenInfo; }; type PipeTransportListenIp = { /** * Listening IP address. */ listenIp: TransportListenIp | string; /** * Fixed port to listen on instead of selecting automatically from Worker's * port range. */ port?: number; }; export type PipeConsumerOptions = { /** * The id of the Producer to consume. */ producerId: string; /** * Custom application data. */ appData?: ConsumerAppData; }; export type PipeTransportDump = BaseTransportDump & { tuple: TransportTuple; rtx: boolean; srtpParameters?: SrtpParameters; }; export type PipeTransportStat = BaseTransportStats & { type: string; tuple: TransportTuple; }; export type PipeTransportEvents = TransportEvents & { sctpstatechange: [SctpState]; }; export type PipeTransportObserver = EnhancedEventEmitter; export type PipeTransportObserverEvents = TransportObserverEvents & { sctpstatechange: [SctpState]; }; export interface PipeTransport extends Transport { /** * Transport type. * * @override */ get type(): 'pipe'; /** * Observer. * * @override */ get observer(): PipeTransportObserver; /** * PipeTransport tuple. */ get tuple(): TransportTuple; /** * SCTP parameters. */ get sctpParameters(): SctpParameters | undefined; /** * SCTP state. */ get sctpState(): SctpState | undefined; /** * SCTP negotiated capabilities. * * @remarks * - Only present if SCTP association is connected. */ get sctpNegotiatedCapabilities(): SctpNegotiatedCapabilities | undefined; /** * SRTP parameters. */ get srtpParameters(): SrtpParameters | undefined; /** * Dump PipeTransport. * * @override */ dump(): Promise; /** * Get PipeTransport stats. * * @override */ getStats(): Promise; /** * Provide the PipeTransport remote parameters. * * @override */ connect({ ip, port, srtpParameters, }: { ip: string; port: number; srtpParameters?: SrtpParameters; }): Promise; /** * Create a pipe Consumer. * * @override */ consume({ producerId, appData, }: PipeConsumerOptions): Promise>; } export {}; //# sourceMappingURL=PipeTransportTypes.d.ts.map