Send a flashblock to the background processor and wait until it is handled.
(&self, flashblock: Flashblock)
| 73 | |
| 74 | /// Send a flashblock to the background processor and wait until it is handled. |
| 75 | pub async fn send(&self, flashblock: Flashblock) -> Result<()> { |
| 76 | let (tx, rx) = oneshot::channel(); |
| 77 | self.sender.send((flashblock, tx)).await.map_err(|err| eyre::eyre!(err))?; |
| 78 | rx.await.map_err(|err| eyre::eyre!(err))?; |
| 79 | Ok(()) |
| 80 | } |
| 81 | } |
| 82 | |
| 83 | /// Test extension for flashblocks functionality. |
no outgoing calls
no test coverage detected