()
| 1324 | } |
| 1325 | |
| 1326 | fn empty_tx_update() -> SerializableMessage { |
| 1327 | let msg = TransactionUpdateMessage { |
| 1328 | event: None, |
| 1329 | database_update: SubscriptionUpdateMessage::default_for_protocol(Protocol::Binary, None), |
| 1330 | }; |
| 1331 | SerializableMessage::TxUpdate(msg) |
| 1332 | } |
| 1333 | |
| 1334 | async fn assert_received_update(f: impl Future<Output = Option<OutboundMessage>>) { |
| 1335 | assert_matches!(f.await, Some(OutboundMessage::V1(SerializableMessage::TxUpdate(_)))); |
no outgoing calls
no test coverage detected
searching dependent graphs…