Тестирование F # async рабочих процессов с поддержкой поддержки xUnit.net

Question

Я пишу код F # и тесты в xUnit 1.9.

Для нормальной работы с синхронизацией я просто возвращаю unit, и все хорошо; но теперь я переношу синхронизацию, чтобы быть рабочими потоками async.

Другими словами, мой простой AAA становится явным Async использование выталкивается в него, как я реорганизовать систему:

let [<Fact>] ``Can consume using NEventStore InMemory``() = 
    let store = NesGateway.createInMemory() 

    let finalDirection = playCircuit store |> Async.RunSynchronously // <----- YUCK 

    test <@ CounterClockWise = finalDirection @> 

Чтобы исправить это, я хочу, чтобы сделать тело теста быть async. Однако, насколько мне известно, xUnit.net управляет только методами, возвращающими Task -развернутыми типами, и, следовательно, мне нужен безопасный способ, чтобы мое тестовое тело async было удобно обернуто для бегуна xUnit.net, чтобы поднять его и обработать соответствующим образом ,

Каков наилучший способ выразить мой тест выше?

Answer 1

В рамках XUnit 2,2 Beta 3, Уилсон @ Брэд сделал the necessary to make it work natively directly. Поэтому теперь можно просто написать:

let [<Fact>] ``Can consume NEventStore InMemory``() = async { 
    let store = NesGateway.createInMemory() 

    let! finalDirection = playCircuit store 

    test <@ CounterClockWise = finalDirection @> } 

Answer 2

К сожалению (в меру моих знаний [который не говорит много, поэтому вопрос]), чистейшее, что это возможно, чтобы использовать Async.StartAsTask <| async applelation Thusly:

let [<Fact>] ``Can consume NEventStore InMemory``() = Async.StartAsTask <| async { 
    let store = NesGateway.createInMemory() 

    let! finalDirection = playCircuit store 

    test <@ CounterClockWise = finalDirection @> } 

---

Или, для немного большей безопасности (в асинхронном [Fact] не будут признаны в качестве синхронизации с помощью xUnit.net, если тип возвращаемого не [получен из] Task) и [возможно] чистота (читает лучше):

// Ensure we match the return type xUnit.net is looking for 
let toFact computation : Task = Async.StartAsTask computation :> _ 

let [<Fact>] ``Can play a circuit using GES``() = toFact <| async { 
    use! store = createStore() 
    let! finalDirection = playCircuit store 
    CounterClockWise =! finalDirection } 

Answer 3

Вы также можете создать собственное выражение вычисления инкапсулировать Async.RunSynchronously вызова:

type AsyncTestBuilder() = 
    member this.Bind (v: Async<'a>, c: 'a -> 'b) = v |> Async.RunSynchronously |> c; 
    member this.Zero() =() 

let asyncTest = AsyncTestBuilder() 

let [<Fact>] ``Can consume using NEventStore InMemory``() = asyncTest { 
    let store = NesGateway.createInMemory() 

    let! finalDirection = playCircuit store // <-- use let! instead of let 

    test <@ CounterClockWise = finalDirection @> } 

Answer 4

Pre XUnit 2,2, вы можете использовать TaskBuilder для получения Task<T>, используя тот же стиль, как async: -

let [<Fact>] ``Can consume NEventStore InMemory``() = task { 
    let store = NesGateway.createInMemory() 

    let! finalDirection = playCircuit store 

    test <@ CounterClockWise = finalDirection @> } 

Отрывок (не принимать его, принять the full source, как вы найдете, что это актуально для всех видов Task -munging):

open System.Threading 
open System.Threading.Tasks 

[<AbstractClass>] 
type AsyncBuilderAbstract() = 
    // AsyncBuilder is marked sealed, so we need this wrapper 
    member __.Zero() = async.Zero() 
    member __.Return t = async.Return t 
    member __.ReturnFrom t = async.ReturnFrom t 
    member __.Bind(f,g) = async.Bind(f,g) 
    member __.Combine(f,g) = async.Combine(f,g) 
    member __.Delay f = async.Delay f 
    member __.While(c,b) = async.While(c,b) 
    member __.For(xs,b) = async.For(xs,b) 
    member __.TryWith(b,e) = async.TryWith(b,e) 

type TaskBuilder(?ct : CancellationToken) = 
    inherit AsyncBuilderAbstract() 
    member __.Run f : Task<'T> = Async.StartAsTask(f, ?cancellationToken = ct) 

type UntypedTaskBuilder(?ct : CancellationToken) = 
    inherit AsyncBuilderAbstract() 
    member __.Run f : Task = Async.StartAsTask(f, ?cancellationToken = ct) :> Task 

let task = new TaskBuilder()