Ask a question to get started
Enter to send•Shift+Enter new line
Map input chunk to a sequence of pending writes in the form (channel, value).
map_input( input_channels: str | Sequence[str], chunk: dict[str, Any] | Any | None ) -> Iterator[tuple[str, Any]]