| 407 | } |
| 408 | |
| 409 | fn to_upstream_message(message: Message) -> Option<UpstreamMessage> { |
| 410 | match message { |
| 411 | Message::Text(text) => Some(UpstreamMessage::Text(text.to_string().into())), |
| 412 | Message::Binary(bytes) => Some(UpstreamMessage::Binary(bytes)), |
| 413 | Message::Ping(bytes) => Some(UpstreamMessage::Ping(bytes)), |
| 414 | Message::Pong(bytes) => Some(UpstreamMessage::Pong(bytes)), |
| 415 | Message::Close(_) => None, |
| 416 | } |
| 417 | } |
| 418 | |
| 419 | fn to_downstream_message(message: UpstreamMessage) -> Option<Message> { |
| 420 | match message { |