File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
timely/src/dataflow/channels Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change 6565{
6666 fn from_bytes ( mut bytes : crate :: bytes:: arc:: Bytes ) -> Self {
6767 let mut slice = & bytes[ ..] ;
68- let from: usize = :: bincode:: deserialize ( & mut slice) . expect ( "bincode::deserialize() failed" ) ;
69- let seq: usize = :: bincode:: deserialize ( & mut slice) . expect ( "bincode::deserialize() failed" ) ;
70- let time: T = :: bincode:: deserialize ( & mut slice) . expect ( "bincode::deserialize() failed" ) ;
68+ let from: usize = :: bincode:: deserialize_from ( & mut slice) . expect ( "bincode::deserialize() failed" ) ;
69+ let seq: usize = :: bincode:: deserialize_from ( & mut slice) . expect ( "bincode::deserialize() failed" ) ;
70+ let time: T = :: bincode:: deserialize_from ( & mut slice) . expect ( "bincode::deserialize() failed" ) ;
7171 let bytes_read = bytes. len ( ) - slice. len ( ) ;
7272 bytes. extract_to ( bytes_read) ;
7373 let data: C = ContainerBytes :: from_bytes ( bytes) ;
You can’t perform that action at this time.
0 commit comments