File tree Expand file tree Collapse file tree 4 files changed +4
-2
lines changed
Expand file tree Collapse file tree 4 files changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -156,6 +156,7 @@ mod tests {
156156 struct TestRetryLogic ;
157157 impl RetryLogic for TestRetryLogic {
158158 type Error = TestError ;
159+ type Request = ( ) ;
159160 type Response = String ;
160161 fn is_retriable_error ( & self , _error : & Self :: Error ) -> bool {
161162 true
Original file line number Diff line number Diff line change @@ -321,6 +321,7 @@ enum Error {
321321struct TestRetryLogic ;
322322
323323impl RetryLogic for TestRetryLogic {
324+ type Request = Vec < Event > ;
324325 type Response = Response ;
325326 type Error = Error ;
326327
Original file line number Diff line number Diff line change @@ -953,7 +953,7 @@ mod test {
953953
954954 #[ test]
955955 fn util_http_retry_logic ( ) {
956- let logic = HttpRetryLogic :: default ( ) ;
956+ let logic = HttpRetryLogic :: < ( ) > :: default ( ) ;
957957
958958 let response_408 = Response :: builder ( ) . status ( 408 ) . body ( Bytes :: new ( ) ) . unwrap ( ) ;
959959 let response_429 = Response :: builder ( ) . status ( 429 ) . body ( Bytes :: new ( ) ) . unwrap ( ) ;
Original file line number Diff line number Diff line change @@ -561,7 +561,7 @@ mod tests {
561561 ) ;
562562 sink. ordered ( ) ;
563563
564- let input = ( 0 ..20 ) . map ( |i| PartitionInnerBuffer :: new ( i, 0 ) ) ;
564+ let input = ( 0 ..20 ) . map ( |i| PartitionInnerBuffer :: new ( i, vec ! [ 0 ] ) ) ;
565565 sink. sink_map_err ( drop)
566566 . send_all (
567567 & mut stream:: iter ( input)
You can’t perform that action at this time.
0 commit comments