Merge pull request #662 from frankmcsherry/further_cleanup

Further cleanup

Author: frankmcsherry

communication/src/allocator/zero_copy/allocator.rs

@@ -261,7 +261,7 @@ impl<A: Allocate> Allocate for TcpAllocator<A> {
 
             // We expect that `bytes` contains an integral number of messages.
             // No splitting occurs across allocations.
-            while bytes.len() > 0 {
+            while !bytes.is_empty() {
 
                 if let Some(header) = MessageHeader::try_read(&bytes[..]) {
 

communication/src/allocator/zero_copy/allocator_process.rs

@@ -188,7 +188,7 @@ impl Allocate for ProcessAllocator {
 
             // We expect that `bytes` contains an integral number of messages.
             // No splitting occurs across allocations.
-            while bytes.len() > 0 {
+            while !bytes.is_empty() {
 
                 if let Some(header) = MessageHeader::try_read(&bytes[..]) {
 

timely/src/dataflow/stream.rs

@@ -95,7 +95,6 @@ where
     fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
         f.debug_struct("Stream")
             .field("source", &self.name)
-            // TODO: Use `.finish_non_exhaustive()` after rust/#67364 lands
-            .finish()
+            .finish_non_exhaustive()
     }
 }