fn into_streaming_request()

in dubbo/src/invocation.rs [135:142]

• 6 lines of code
• 2 McCabe index (conditional complexity)

    fn into_streaming_request(self) -> Request<Self::Stream>;
}

impl<T> IntoStreamingRequest for T
where
    T: Stream + Send + 'static,
    // T::Item: Result<Self::Message, std::convert::Infallible>,
{