Replace impl TryStream with impl Stream

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,