Как я просто вызываю метод службы asyc WCF, используя Rx

Question

Я изо всех сил пытался понять, как использовать Rx. Большинство примеров устарели, ссылаются на начало / конец или длинные и сложные.

У меня есть простой метод службы WCF, который принимает int и возвращает объект JobMaster.

Вот как я это называю сейчас:

    public static void GetJob(int jobId)
    {
        KernServiceClient.GetJobCompleted += GetJobCompleted;
        KernServiceClient.GetJobAsync(jobId);
    }

    private static void GetJobCompleted(object sender, GetJobCompletedEventArgs e)
    {
        // JobMaster available in e.Result
    }

Как мне изменить это, чтобы использовать Rx?

EDIT

Благодаря помощи Пола я проделал большую часть пути туда. Вот как это выглядит сейчас. Единственная проблема - подписка никогда не срабатывает. Есть идеи?

    public static JobMaster GetJob(int jobId)
    {
        JobMaster retval = null;

        IKernService kernServiceInterface = KernServiceClient;

        var getJobFunc = Observable.FromAsyncPattern<int, Server.KernMobileWcfService.JobMaster>(
            kernServiceInterface.BeginGetJob, kernServiceInterface.EndGetJob);

        var result = getJobFunc(jobId);

        result
            .Subscribe
            (
                onNext: x => retval = ConvertJobMaster(x),
                onError: ex => ShowError(ex.Message)
            );

        return retval;
    }

Answer 1

http://blog.paulbetts.org/index.php/2010/09/26/calling-web-services-in-silverlight-using-reactivexaml/ // Игнорировать часть ReactiveXaml

Описание: приведите KernServiceClient к интерфейсу, который он реализует для возврата методов Begin / End, используйте FromAsyncPattern.

Answer 2

что вы делаете с retval когда вы его возвращаете?если вам нужно выполнить дополнительную обработку при следующем завершении, сделайте это в событии onCompleted подписки

Answer 3

Кажется, вы возвращаете "retval", даже если вы вычисляете его асинхронно и назначаете его из обработчика OnNext.Ваша логика после получения значения от службы должна быть перемещена в обработчик OnNext, или вы должны вернуть IObservable вызывающей стороне.