(
&mut self,
channel: ChannelId,
data: &[u8],
_session: &mut Session,
)
| 504 | } |
| 505 | |
| 506 | async fn data( |
| 507 | &mut self, |
| 508 | channel: ChannelId, |
| 509 | data: &[u8], |
| 510 | _session: &mut Session, |
| 511 | ) -> Result<(), Self::Error> { |
| 512 | let Some(state) = self.channels.get(&channel) else { |
| 513 | warn!("data on unknown channel {channel:?}"); |
| 514 | return Ok(()); |
| 515 | }; |
| 516 | if let Some(sender) = state.input_sender.as_ref() { |
| 517 | let _ = sender.send(data.to_vec()); |
| 518 | } |
| 519 | Ok(()) |
| 520 | } |
| 521 | |
| 522 | async fn channel_eof( |
| 523 | &mut self, |
no test coverage detected