You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
// using the `AsyncReadExt::read` extension method (higher-level)
44
44
letmut buffer1 = [0u8;64];
45
-
let bytes_read1 = futures::io::AsyncReadExt::read(&mut reader,&mut buffer1).await?;// we cannot resolve the `read` call, which comes from `impl<R: AsyncRead + ?Sized> AsyncReadExt for R {}` in `async_read_ext.rs`
45
+
let bytes_read1 = futures::io::AsyncReadExt::read(&mut reader,&mut buffer1).await?;
let bytes_read2 = reader.read(&mut buffer2).await?;// we cannot resolve the `read` call, which comes from `impl<R: AsyncRead + ?Sized> AsyncReadExt for R {}` in `async_read_ext.rs`
49
+
let bytes_read2 = reader.read(&mut buffer2).await?;
// using the `AsyncBufReadExt::fill_buf` extension method (higher-level)
83
-
let buffer = reader2.fill_buf().await?;// we cannot resolve the `fill_buf` call, which comes from `impl<R: AsyncBufRead + ?Sized> AsyncBufReadExt for R {}` in `async_buf_read_ext.rs`
// using the `AsyncReadExt::read` extension method (higher-level)
102
102
letmut buffer1 = [0u8;64];
103
-
let bytes_read1 = futures::io::AsyncReadExt::read(&mut reader2,&mut buffer1).await?;// we cannot resolve the `read` call, which comes from `impl<R: AsyncRead + ?Sized> AsyncReadExt for R {}` in `async_read_ext.rs`
103
+
let bytes_read1 = futures::io::AsyncReadExt::read(&mut reader2,&mut buffer1).await?;
let bytes_read2 = reader2.read(&mut buffer2).await?;// we cannot resolve the `read` call, which comes from `impl<R: AsyncRead + ?Sized> AsyncReadExt for R {}` in `async_read_ext.rs`
107
+
let bytes_read2 = reader2.read(&mut buffer2).await?;
// using the `AsyncBufReadExt::fill_buf` extension method (higher-level)
125
-
let buffer = reader2.fill_buf().await?;// we cannot resolve the `fill_buf` call, which comes from `impl<R: AsyncBufRead + ?Sized> AsyncBufReadExt for R {}` in `async_buf_read_ext.rs`
125
+
let buffer = reader2.fill_buf().await?;
126
126
sink(buffer);// $ hasTaintFlow=url
127
127
}
128
128
129
129
{
130
130
// using the `AsyncBufReadExt::read_until` extension method
131
131
letmut line = Vec::new();
132
-
let _bytes_read = reader2.read_until(b'\n',&mut line).await?;// we cannot resolve the `read_until` call, which comes from `impl<R: AsyncBufRead + ?Sized> AsyncBufReadExt for R {}` in `async_buf_read_ext.rs`
132
+
let _bytes_read = reader2.read_until(b'\n',&mut line).await?;
133
133
sink(&line);// $ hasTaintFlow=url
134
134
}
135
135
136
136
{
137
137
// using the `AsyncBufReadExt::read_line` extension method
138
138
letmut line = String::new();
139
-
let _bytes_read = reader2.read_line(&mut line).await?;// we cannot resolve the `read_line` call, which comes from `impl<R: AsyncBufRead + ?Sized> AsyncBufReadExt for R {}` in `async_buf_read_ext.rs`
139
+
let _bytes_read = reader2.read_line(&mut line).await?;
140
140
sink(&line);// $ hasTaintFlow=url
141
141
}
142
142
143
143
{
144
144
// using the `AsyncBufReadExt::read_to_end` extension method
145
145
letmut buffer = Vec::with_capacity(1024);
146
-
let _bytes_read = reader2.read_to_end(&mut buffer).await?;// we cannot resolve the `read` call, which comes from `impl<R: AsyncRead + ?Sized> AsyncReadExt for R {}` in `async_read_ext.rs`
146
+
let _bytes_read = reader2.read_to_end(&mut buffer).await?;
147
147
sink(&buffer);// $ hasTaintFlow=url
148
148
}
149
149
150
150
{
151
151
// using the `AsyncBufReadExt::lines` extension method
152
-
letmut lines_stream = reader2.lines();// we cannot resolve the `lines` call, which comes from `impl<R: AsyncBufRead + ?Sized> AsyncBufReadExt for R {}` in `async_buf_read_ext.rs`
0 commit comments