use new rpc-stream
update to new rpc-stream api