Replace impl TryStream with impl Stream

The problem with `impl TryStream` is that the opaque type cannot be used as `Stream` (thus `StreamExt`) anymore, only `TryStream`, because types implementing the latter does not necessarily implement the former. This also causes problems with dynamic dispatch. By making this change we can use methods from both traits and should not break users' current usage.

Author: hack3ric

src/addr/get.rs

@@ -2,7 +2,7 @@
 
 use futures::{
     future::{self, Either},
-    stream::{StreamExt, TryStream, TryStreamExt},
+    stream::{Stream, StreamExt, TryStreamExt},
     FutureExt,
 };
 use std::net::IpAddr;
@@ -34,7 +34,7 @@ impl AddressGetRequest {
         &mut self.message
     }
 
-    pub fn execute(self) -> impl TryStream<Ok = AddressMessage, Error = Error> {
+    pub fn execute(self) -> impl Stream<Item = Result<AddressMessage, Error>> {
         let AddressGetRequest {
             mut handle,
             message,

src/link/get.rs

@@ -2,7 +2,7 @@
 
 use futures::{
     future::{self, Either},
-    stream::{StreamExt, TryStream},
+    stream::{Stream, StreamExt},
     FutureExt,
 };
 use netlink_packet_core::{NetlinkMessage, NLM_F_DUMP, NLM_F_REQUEST};
@@ -48,7 +48,7 @@ impl LinkGetRequest {
     }
 
     /// Execute the request
-    pub fn execute(self) -> impl TryStream<Ok = LinkMessage, Error = Error> {
+    pub fn execute(self) -> impl Stream<Item = Result<LinkMessage, Error>> {
         let LinkGetRequest {
             mut handle,
             message,

src/neighbour/get.rs

@@ -2,7 +2,7 @@
 
 use futures::{
     future::{self, Either},
-    stream::{StreamExt, TryStream},
+    stream::{Stream, StreamExt},
     FutureExt,
 };
 use netlink_packet_core::{
@@ -41,7 +41,7 @@ impl NeighbourGetRequest {
     /// Execute the request
     pub fn execute(
         self,
-    ) -> impl TryStream<Ok = NeighbourMessage, Error = Error> {
+    ) -> impl Stream<Item = Result<NeighbourMessage, Error>> {
         let NeighbourGetRequest {
             mut handle,
             message,

src/route/get.rs

@@ -2,7 +2,7 @@
 
 use futures::{
     future::{self, Either},
-    stream::{StreamExt, TryStream},
+    stream::{Stream, StreamExt},
     FutureExt,
 };
 
@@ -45,7 +45,7 @@ impl RouteGetRequest {
         &mut self.message
     }
 
-    pub fn execute(self) -> impl TryStream<Ok = RouteMessage, Error = Error> {
+    pub fn execute(self) -> impl Stream<Item = Result<RouteMessage, Error>> {
         let RouteGetRequest {
             mut handle,
             message,

src/rule/get.rs

@@ -2,7 +2,7 @@
 
 use futures::{
     future::{self, Either},
-    stream::{StreamExt, TryStream},
+    stream::{Stream, StreamExt},
     FutureExt,
 };
 use netlink_packet_core::{NetlinkMessage, NLM_F_DUMP, NLM_F_REQUEST};
@@ -37,7 +37,7 @@ impl RuleGetRequest {
         &mut self.message
     }
 
-    pub fn execute(self) -> impl TryStream<Ok = RuleMessage, Error = Error> {
+    pub fn execute(self) -> impl Stream<Item = Result<RuleMessage, Error>> {
         let RuleGetRequest {
             mut handle,
             message,

src/traffic_control/get.rs

@@ -2,7 +2,7 @@
 
 use futures::{
     future::{self, Either},
-    stream::{StreamExt, TryStream},
+    stream::{Stream, StreamExt},
     FutureExt,
 };
 use netlink_packet_core::{NetlinkMessage, NLM_F_DUMP, NLM_F_REQUEST};
@@ -27,7 +27,7 @@ impl QDiscGetRequest {
     }
 
     /// Execute the request
-    pub fn execute(self) -> impl TryStream<Ok = TcMessage, Error = Error> {
+    pub fn execute(self) -> impl Stream<Item = Result<TcMessage, Error>> {
         let QDiscGetRequest {
             mut handle,
             message,
@@ -73,7 +73,7 @@ impl TrafficClassGetRequest {
     }
 
     /// Execute the request
-    pub fn execute(self) -> impl TryStream<Ok = TcMessage, Error = Error> {
+    pub fn execute(self) -> impl Stream<Item = Result<TcMessage, Error>> {
         let TrafficClassGetRequest {
             mut handle,
             message,
@@ -107,7 +107,7 @@ impl TrafficFilterGetRequest {
     }
 
     /// Execute the request
-    pub fn execute(self) -> impl TryStream<Ok = TcMessage, Error = Error> {
+    pub fn execute(self) -> impl Stream<Item = Result<TcMessage, Error>> {
         let TrafficFilterGetRequest {
             mut handle,
             message,
@@ -148,7 +148,7 @@ impl TrafficChainGetRequest {
     }
 
     /// Execute the request
-    pub fn execute(self) -> impl TryStream<Ok = TcMessage, Error = Error> {
+    pub fn execute(self) -> impl Stream<Item = Result<TcMessage, Error>> {
         let TrafficChainGetRequest {
             mut handle,
             message,