-
Notifications
You must be signed in to change notification settings - Fork 0
Open
Description
- Add configurable options to add hook functions to filter or mutate inbound / outbound messages on WebSocket channels:
- Client callbacks (topic, message, data):
- BeforeMessageSent
- AfterMessageReceived
- Server:
- BeforeMessageSent (before the pipeline)
- AfterMessageReceived (after the pipeline)
- Client callbacks (topic, message, data):
- Use OmegaConf
- Consider what naming to use
- Consider what signature to use. Take into account that the customer may not use IDE to write to hooks. So the signature should probable avoid relying on complex typing
- For example
__call__(topic: str, m: Message, payload: bytes) -> Optional[Tuple(str, Message, bytes)]
- For example
- Add corresponding docs
Metadata
Metadata
Assignees
Labels
No labels