Add timeout + tests
Execute methods in rpc stream context