@@ -70,12 +70,6 @@ impl From<tokio::sync::oneshot::error::RecvError> for SendError {
7070/// which only make sense in the context of the public API.
7171#[ derive( Debug , Error ) ]
7272pub ( crate ) enum InternalSendError {
73- /// The session is disconnected. Currently unused as internal sends don't
74- /// check connection state, but kept for symmetry with `SendError`.
75- #[ allow( dead_code) ]
76- #[ error( "session is disconnected" ) ]
77- Disconnected ,
78-
7973 #[ error( "failed to persist message" ) ]
8074 Persist ( #[ source] StoreError ) ,
8175
@@ -86,7 +80,6 @@ pub(crate) enum InternalSendError {
8680impl From < InternalSendError > for SendError {
8781 fn from ( err : InternalSendError ) -> Self {
8882 match err {
89- InternalSendError :: Disconnected => SendError :: Disconnected ,
9083 InternalSendError :: Persist ( e) => SendError :: Persist ( e) ,
9184 InternalSendError :: SequenceNumber ( e) => SendError :: SequenceNumber ( e) ,
9285 }
@@ -160,13 +153,6 @@ mod tests {
160153 assert ! ( matches!( err, SendError :: SessionGone ) ) ;
161154 }
162155
163- #[ test]
164- fn internal_send_error_disconnected_converts_to_send_error ( ) {
165- let internal_err = InternalSendError :: Disconnected ;
166- let send_err: SendError = internal_err. into ( ) ;
167- assert ! ( matches!( send_err, SendError :: Disconnected ) ) ;
168- }
169-
170156 #[ test]
171157 fn internal_send_error_persist_converts_to_send_error ( ) {
172158 let internal_err = InternalSendError :: Persist ( test_store_error ( ) ) ;
0 commit comments