(&self, id: &str)
| 542 | } |
| 543 | |
| 544 | fn send_stream_end(&self, id: &str) -> FlowResult<()> { |
| 545 | self.write_command(&json!({ |
| 546 | "id": id, |
| 547 | "command": "stream_end", |
| 548 | })) |
| 549 | } |
| 550 | |
| 551 | fn forget_stream(&self, id: &str) { |
| 552 | let _ = self |
nothing calls this directly
no test coverage detected