Utility for creating an Ethereum web3 provider that forwards payloads through a stream. Only works for async payloads.
For connecting to a remote eth rpc handler
const StreamProvider = require('web3-stream-provider')
var streamProvider = new StreamProvider()
var web3 = new Web3(streamProvider)
streamProvider.pipe(remoteRpcHandler).pipe(streamProvider)For handling incoming rpc payloads
const handleRequestsFromStream = require('web3-stream-provider/handler')
handleRequestsFromStream(remoteStream, provider, /* optional */ onRequest, onResponse)
function onRequest(request){
// can modify the request if needed
console.log(arguments)
}
function onResponse(err, request, response){
console.log(arguments)
}