File tree Expand file tree Collapse file tree 2 files changed +2
-3
lines changed Expand file tree Collapse file tree 2 files changed +2
-3
lines changed Original file line number Diff line number Diff line change 44pub mod managed;
55pub use managed:: ManagedBlockPool ;
66
7+ use anyhow:: Result ;
78use derive_builder:: Builder ;
89use derive_getters:: Dissolve ;
910use serde:: { Deserialize , Serialize } ;
@@ -31,8 +32,6 @@ use tokio::runtime::Handle;
3132use tokio:: sync:: oneshot;
3233use tokio_util:: sync:: CancellationToken ;
3334
34- use dynamo_runtime:: Result ;
35-
3635// Type aliases to reduce complexity across the module
3736type BlockPoolResult < T > = Result < T , BlockPoolError > ;
3837type AsyncResponse < T > = Result < oneshot:: Receiver < T > , BlockPoolError > ;
Original file line number Diff line number Diff line change @@ -217,7 +217,7 @@ impl Server {
217217 mpsc:: error:: TrySendError :: Full ( data) => {
218218 tracing:: warn!(
219219 request_id,
220- "response stream is full; backpressue alert"
220+ "response stream is full; backpressure alert"
221221 ) ;
222222 // todo - add timeout - we are blocking all other streams
223223 if ( tx. send ( data) . await ) . is_err ( ) {
You can’t perform that action at this time.
0 commit comments