Creates an operator that selects only messages whose topic matches the specified topic and emits the associated data payload.
This is commonly used when incoming data arrives as [topic, payload] tuples.
[topic, payload]
Operator that emits only payloads belonging to the given topic.
source$.pipe( selectMotionMasterMessageByTopic<DeviceStatus>('device/status')).subscribe(status => console.log(status));
The payload type associated with the topic.
Topic identifier to match.
Generated using TypeDoc
Creates an operator that selects only messages whose topic matches the specified topic and emits the associated data payload.
This is commonly used when incoming data arrives as
[topic, payload]tuples.Returns
Operator that emits only payloads belonging to the given topic.
Example