다음을 통해 공유


PayloadAssemblerManager class

페이로드의 어셈블리를 오케스트레이션합니다.

생성자

PayloadAssemblerManager(StreamManager, (id: string, receiveResponse: IReceiveResponse) => Promise<void>, (id: string, receiveRequest: IReceiveRequest) => Promise<void>)

PayloadAssemblerManager 클래스의 새 인스턴스를 초기화합니다.

메서드

getPayloadStream(IHeader)

어셈블러의 페이로드를 스트림으로 검색합니다.

onReceive(IHeader, SubscribableStream, number)

들어오는 스트림에서 새 바이트를 받을 때 어셈블러가 실행하는 작업입니다.

생성자 세부 정보

PayloadAssemblerManager(StreamManager, (id: string, receiveResponse: IReceiveResponse) => Promise<void>, (id: string, receiveRequest: IReceiveRequest) => Promise<void>)

PayloadAssemblerManager 클래스의 새 인스턴스를 초기화합니다.

new PayloadAssemblerManager(streamManager: StreamManager, onReceiveResponse: (id: string, receiveResponse: IReceiveResponse) => Promise<void>, onReceiveRequest: (id: string, receiveRequest: IReceiveRequest) => Promise<void>)

매개 변수

onReceiveResponse

(id: string, receiveResponse: IReceiveResponse) => Promise<void>

response 스트림에서 새 바이트를 받을 때 실행되는 함수입니다.

onReceiveRequest

(id: string, receiveRequest: IReceiveRequest) => Promise<void>

request 스트림에서 새 바이트를 받을 때 실행되는 함수입니다.

메서드 세부 정보

getPayloadStream(IHeader)

어셈블러의 페이로드를 스트림으로 검색합니다.

function getPayloadStream(header: IHeader): SubscribableStream

매개 변수

header
IHeader

검색할 스트림의 헤더입니다.

반환

어셈블러 페이로드의 SubscribableStream.

onReceive(IHeader, SubscribableStream, number)

들어오는 스트림에서 새 바이트를 받을 때 어셈블러가 실행하는 작업입니다.

function onReceive(header: IHeader, contentStream: SubscribableStream, contentLength: number)

매개 변수

header
IHeader

스트림의 헤더입니다.

contentStream
SubscribableStream

어셈블되는 들어오는 스트림입니다.

contentLength

number

스트림의 길이(유한한 경우)입니다.