Function next_within 

pub(crate) async fn next_within(
    socket: &mut WebSocketStream<MaybeTlsStream<TcpStream>>,
    seconds: u64,
) -> Option<Result<Message, Error>>

The socket’s next message, or None once it stops arriving.