StreamManager class
스트림을 오케스트레이션하고 관리합니다.
생성자
| Stream |
StreamManager 클래스의 새 인스턴스를 초기화합니다. |
메서드
| close |
지정된 ID를 사용하여 SubscribableStream에 할당된 PayloadAssembler를 닫습니다. |
| get |
지정된 ID가 있는 경우 PayloadAssembler 를 검색합니다. 그렇지 않으면 새 인스턴스가 만들어지고 지정된 ID가 할당됩니다. |
| get |
이 관리자가 관리하는 PayloadAssembler에서 SubscribableStream을 검색합니다. |
| on |
데이터를 받을 때 관리되는 PayloadAssembler 의 동작을 설정하는 데 사용됩니다. |
생성자 세부 정보
StreamManager((contentStreamAssembler: PayloadAssembler) => void)
StreamManager 클래스의 새 인스턴스를 초기화합니다.
new StreamManager(onCancelStream: (contentStreamAssembler: PayloadAssembler) => void)매개 변수
- onCancelStream
-
(contentStreamAssembler: PayloadAssembler) => void
관리되는 스트림이 취소되면 트리거하는 함수입니다.
메서드 세부 정보
closeStream(string)
지정된 ID를 사용하여 SubscribableStream에 할당된 PayloadAssembler를 닫습니다.
function closeStream(id: string)매개 변수
- id
-
string
닫을 SubscribableStream 의 ID입니다.
getPayloadAssembler(string)
지정된 ID가 있는 경우 PayloadAssembler 를 검색합니다. 그렇지 않으면 새 인스턴스가 만들어지고 지정된 ID가 할당됩니다.
function getPayloadAssembler(id: string): PayloadAssembler매개 변수
- id
-
string
검색하거나 만들 PayloadAssembler 의 ID입니다.
반환
지정된 ID가 있는 PayloadAssembler 입니다.
getPayloadStream(IHeader)
이 관리자가 관리하는 PayloadAssembler에서 SubscribableStream을 검색합니다.
function getPayloadStream(header: IHeader): SubscribableStream매개 변수
- header
- IHeader
검색할 SubscribableStream 의 헤더입니다.
반환
지정된 헤더 가 있는 SubscribableStream 입니다.
onReceive(IHeader, SubscribableStream, number)
데이터를 받을 때 관리되는 PayloadAssembler 의 동작을 설정하는 데 사용됩니다.
function onReceive(header: IHeader, contentStream: SubscribableStream, contentLength: number)매개 변수
- header
- IHeader
스트림의 헤더입니다.
- contentStream
- SubscribableStream
들어오는 데이터를 쓸 SubscribableStream 입니다.
- contentLength
-
number
contentStream에 쓸 데이터의 양입니다.