beam/jobs: stream-oriented rpc