Function FakeRPC

test/async.go:27–39

FakeRPC returns a blocking async function which simulates an RPC that succeeds after a short delay, or fails if the provided per-call timeout elapses first.

(timeout time.Duration)

// FakeRPC returns a blocking async function which simulates an RPC that succeeds after a short
// delay, or fails if the provided per-call timeout elapses first.
func FakeRPC(timeout time.Duration) func(context.Context, ...ref.Val) ref.Val {
	return func(ctx context.Context, args ...ref.Val) ref.Val {
		rpcCtx, cancel := context.WithTimeout(ctx, timeout)
		defer cancel()
		select {
		case <-time.After(20 * time.Millisecond):
			in := args[0].(types.String)
			return in.Add(types.String(" success!"))
		case <-rpcCtx.Done():
			return types.NewErr(rpcCtx.Err().Error())
		}
	}
}