Measure serialization/compression time for one websocket payload.
(encode: impl FnOnce() -> (InUseSerializeBuffer, T))
| 1782 | |
| 1783 | /// Measure serialization/compression time for one websocket payload. |
| 1784 | fn time_encode<T>(encode: impl FnOnce() -> (InUseSerializeBuffer, T)) -> (Duration, InUseSerializeBuffer, T) { |
| 1785 | let start = Instant::now(); |
| 1786 | let (in_use, data) = encode(); |
| 1787 | (start.elapsed(), in_use, data) |
| 1788 | } |
| 1789 | |
| 1790 | /// Build binary websocket frames and payload metrics for encoded bytes. |
| 1791 | fn ws_encode_binary_frames( |
no test coverage detected
searching dependent graphs…