()
| 164 | pub fn poll_one() -> Result<Option<SteamEvent>, SteamError> { |
| 165 | queue() |
| 166 | .lock() |
| 167 | .map(|mut queue| queue.pop_front()) |
| 168 | .map_err(|_| SteamError::NotReady) |
| 169 | } |
| 170 | |
| 171 | pub fn drain() -> Result<Vec<SteamEvent>, SteamError> { |
| 172 | queue() |
| 173 | .lock() |
| 174 | .map(|mut queue| queue.drain()) |