diff --git a/web3_proxy/src/jsonrpc/response.rs b/web3_proxy/src/jsonrpc/response.rs index c5c10024..fd1ad868 100644 --- a/web3_proxy/src/jsonrpc/response.rs +++ b/web3_proxy/src/jsonrpc/response.rs @@ -262,6 +262,7 @@ where Some(len) if len <= nbytes => Ok(Self::from_bytes(response.bytes().await?)?), // long Some(_) => Ok(Self::Stream(StreamResponse { + _t: PhantomData::, buffer: Bytes::new(), response, web3_request: web3_request.clone(), @@ -284,6 +285,7 @@ where // we've read nbytes of the response, but there is more to come let buffer = buffer.freeze(); Ok(Self::Stream(StreamResponse { + _t: PhantomData::, buffer, response, web3_request: web3_request.clone(),