Skip to content

Commit 904d458

Browse files
Convert Write::write to Write::write_all (#636)
1 parent 42fe8bc commit 904d458

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

timely/src/dataflow/channels/mod.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -92,7 +92,7 @@ where
9292
::bincode::serialize_into(&mut *writer, &self.time).expect("bincode::serialize_into() failed");
9393
let time_size = ::bincode::serialized_size(&self.time).expect("bincode::serialized_size() failed") as usize;
9494
let time_slop = ((time_size + 7) & !7) - time_size;
95-
writer.write(&[0u8; 8][..time_slop]).unwrap();
95+
writer.write_all(&[0u8; 8][..time_slop]).unwrap();
9696
self.data.into_bytes(&mut *writer);
9797
}
9898
}
@@ -132,7 +132,7 @@ mod implementations {
132132
::bincode::serialize_into(&mut counter, &self).expect("bincode::serialize_into() failed");
133133
let written = counter.count;
134134
let written_slop = ((written + 7) & !7) - written;
135-
counter.write(&[0u8; 8][..written_slop]).unwrap();
135+
counter.write_all(&[0u8; 8][..written_slop]).unwrap();
136136
}
137137
}
138138

@@ -152,7 +152,7 @@ mod implementations {
152152
::bincode::serialize_into(&mut counter, &self).expect("bincode::serialize_into() failed");
153153
let written = counter.count;
154154
let written_slop = ((written + 7) & !7) - written;
155-
counter.write(&[0u8; 8][..written_slop]).unwrap();
155+
counter.write_all(&[0u8; 8][..written_slop]).unwrap();
156156
}
157157
}
158158

timely/src/lib.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -160,7 +160,7 @@ mod encoding {
160160
let typed_size = ::bincode::serialized_size(&self.payload).expect("bincode::serialized_size() failed") as usize;
161161
let typed_slop = ((typed_size + 7) & !7) - typed_size;
162162
::bincode::serialize_into(&mut writer, &self.payload).expect("bincode::serialize_into() failed");
163-
writer.write(&[0u8; 8][..typed_slop]).unwrap();
163+
writer.write_all(&[0u8; 8][..typed_slop]).unwrap();
164164
}
165165
}
166166

0 commit comments

Comments
 (0)