include phantomdata on the streaming response
This commit is contained in:
parent
1178cb61a4
commit
06cd1cc3dd
@ -262,6 +262,7 @@ where
|
|||||||
Some(len) if len <= nbytes => Ok(Self::from_bytes(response.bytes().await?)?),
|
Some(len) if len <= nbytes => Ok(Self::from_bytes(response.bytes().await?)?),
|
||||||
// long
|
// long
|
||||||
Some(_) => Ok(Self::Stream(StreamResponse {
|
Some(_) => Ok(Self::Stream(StreamResponse {
|
||||||
|
_t: PhantomData::<T>,
|
||||||
buffer: Bytes::new(),
|
buffer: Bytes::new(),
|
||||||
response,
|
response,
|
||||||
web3_request: web3_request.clone(),
|
web3_request: web3_request.clone(),
|
||||||
@ -284,6 +285,7 @@ where
|
|||||||
// we've read nbytes of the response, but there is more to come
|
// we've read nbytes of the response, but there is more to come
|
||||||
let buffer = buffer.freeze();
|
let buffer = buffer.freeze();
|
||||||
Ok(Self::Stream(StreamResponse {
|
Ok(Self::Stream(StreamResponse {
|
||||||
|
_t: PhantomData::<T>,
|
||||||
buffer,
|
buffer,
|
||||||
response,
|
response,
|
||||||
web3_request: web3_request.clone(),
|
web3_request: web3_request.clone(),
|
||||||
|
Loading…
Reference in New Issue
Block a user