github/reth
1
1
Fork 0
mirror of https://github.com/paradigmxyz/reth.git synced 2026-01-09 15:28:01 -05:00
Code Issues Packages Projects Releases Wiki Activity

docs(eth-wire): sync code examples with source (#20724)

Browse Source
This commit is contained in:
Sophia Raye
2026-01-03 13:45:07 +03:00
committed by GitHub
parent 0c69e294c3
commit 5307da4794
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
docs/crates/eth-wire.md
View File

@@ -323,7 +323,9 @@ The EthStream wraps a stream and handles eth message (RLP) encoding/decoding wit
[File: crates/net/eth-wire/src/ethstream.rs](../../crates/net/eth-wire/src/ethstream.rs) [File: crates/net/eth-wire/src/ethstream.rs](../../crates/net/eth-wire/src/ethstream.rs)
```rust,ignore ```rust,ignore
#[pin_project] #[pin_project]
pub struct EthStream<S> { pub struct EthStream<S, N = EthNetworkPrimitives> {
/// Eth-specific logic
eth: EthStreamInner<N>,
#[pin] #[pin]
inner: S, inner: S,
} }
@@ -386,7 +388,7 @@ pub struct UnauthedP2PStream<S> {
impl<S> UnauthedP2PStream<S> { impl<S> UnauthedP2PStream<S> {
// ... // ...
pub async fn handshake(mut self, hello: HelloMessageWithProtocols) -> Result<(P2PStream<S>, HelloMessage), Error> { pub async fn handshake(mut self, hello: HelloMessageWithProtocols) -> Result<(P2PStream<S>, HelloMessage), P2PStreamError> {
self.inner.send(alloy_rlp::encode(P2PMessage::Hello(hello.message())).into()).await?; self.inner.send(alloy_rlp::encode(P2PMessage::Hello(hello.message())).into()).await?;
let first_message_bytes = tokio::time::timeout(HANDSHAKE_TIMEOUT, self.inner.next()).await; let first_message_bytes = tokio::time::timeout(HANDSHAKE_TIMEOUT, self.inner.next()).await;