| 1 | | | import '../_impl/xplat/_time_stamp.dart'; |
| 2 | | | |
| 3 | | | extension type StreamId._(int handle) { |
| 4 | | | static int _nextId = 1; |
| 5 | | | |
| 6 | | 15 | factory StreamId.next() => StreamId._(_nextId++); |
| 7 | | | |
| 8 | | 5 | static StreamId? from(dynamic value) => |
| 9 | | 15 | (value is num) ? StreamId._(value.toInt()) : null; |
| 10 | | | } |
| 11 | | | |
| 12 | | | /// Make [WorkerMessage] a `List` to minimize serialization overhead. |
| 13 | | | extension type WorkerMessage(List data) implements Object { |
| 14 | | | /// [travelTime] is set by the receiving end and measures the time (in |
| 15 | | | /// microseconds) it took between the moment the message was serialized and |
| 16 | | | /// the moment it was deserialized. |
| 17 | | 0 | int? get travelTime => data[_$traveltime]; |
| 18 | | | |
| 19 | | 10 | void unwrapTravelTime() { |
| 20 | | 20 | final ts = Timestamp.from(data[_$traveltime]); |
| 21 | | | if (ts != null) { |
| 22 | | 30 | data[_$traveltime] = Timestamp.now() - ts; |
| 23 | | | } |
| 24 | | | } |
| 25 | | | } |
| 26 | | | |
| 27 | | | const _$traveltime = 0; |