在 F# 中,如何判断对象是否为 Async<_>,以及如何将其转换为 Async<_>?
In F#, how do I tell if an object is an Async<_>, and how can I cast it to an Async<_>?
我目前正在尝试创建一个 IHttpActionInvoker
用于 ASP.NET Web API,这将使结果成为 Async<'T>
。目前,我忽略 IHttpActionResult
的转换,只关心 HttpResponseMessage
和 'T
类型的值。我目前有以下实现:
type AsyncApiActionInvoker() =
inherit Controllers.ApiControllerActionInvoker()
override x.InvokeActionAsync(actionContext, cancellationToken) =
if actionContext = null then
raise <| ArgumentNullException("actionContext")
let actionDescriptor = actionContext.ActionDescriptor
Contract.Assert(actionDescriptor <> null)
if actionDescriptor.ReturnType = typeof<Async<HttpResponseMessage>> then
let controllerContext = actionContext.ControllerContext
Contract.Assert(controllerContext <> null)
let task = async {
let! asyncResult = Async.AwaitTask <| actionDescriptor.ExecuteAsync(controllerContext, actionContext.ActionArguments, cancellationToken)
// For now, throw if the result is an IHttpActionResult.
if typeof<IHttpActionResult>.IsAssignableFrom(actionDescriptor.ReturnType) then
raise <| InvalidOperationException("IHttpResult is not supported when returning an Async")
let! result = asyncResult :?> Async<HttpResponseMessage>
return actionDescriptor.ResultConverter.Convert(controllerContext, result) }
Async.StartAsTask(task, cancellationToken = cancellationToken)
else base.InvokeActionAsync(actionContext, cancellationToken)
这仅适用于 Async<HttpResponseMessage>
。如果我尝试转换为 Async<_>
,我会收到一个异常,指出我无法转换为 Async<obj>
。我也无法正确检测 actionDescriptor.ReturnType
是否为 Async<_>
。这并不让我吃惊,但我不确定如何解决这个问题。
在从 Whosebug 外部获得一些有用的提示后,我想出了以下似乎有效的解决方案。我对此并不感到兴奋,但它确实起作用了。如果有任何提示或指示,我将不胜感激:
type AsyncApiActionInvoker() =
inherit Controllers.ApiControllerActionInvoker()
static member internal GetResultConverter(instanceType: Type, actionDescriptor: HttpActionDescriptor) : IActionResultConverter =
if instanceType <> null && instanceType.IsGenericParameter then
raise <| InvalidOperationException()
if instanceType = null || typeof<HttpResponseMessage>.IsAssignableFrom instanceType then
actionDescriptor.ResultConverter
else
let valueConverterType = typedefof<ValueResultConverter<_>>.MakeGenericType instanceType
let newInstanceExpression = Expression.New valueConverterType
let ctor = Expression.Lambda<Func<IActionResultConverter>>(newInstanceExpression).Compile()
ctor.Invoke()
static member internal StartAsTask<'T>(task, resultConverter: IActionResultConverter, controllerContext, cancellationToken) =
let computation = async {
let! comp = Async.AwaitTask task
let! (value: 'T) = unbox comp
return resultConverter.Convert(controllerContext, value) }
Async.StartAsTask(computation, cancellationToken = cancellationToken)
override this.InvokeActionAsync(actionContext, cancellationToken) =
if actionContext = null then
raise <| ArgumentNullException("actionContext")
let actionDescriptor = actionContext.ActionDescriptor
Contract.Assert(actionDescriptor <> null)
let returnType = actionDescriptor.ReturnType
// For now, throw if the result is an IHttpActionResult.
if typeof<IHttpActionResult>.IsAssignableFrom(returnType) then
raise <| InvalidOperationException("IHttpResult is not supported when returning an Async")
if returnType.IsGenericType && returnType.GetGenericTypeDefinition() = typedefof<Async<_>> then
let controllerContext = actionContext.ControllerContext
Contract.Assert(controllerContext <> null)
let computation = actionDescriptor.ExecuteAsync(controllerContext, actionContext.ActionArguments, cancellationToken)
let innerReturnType = returnType.GetGenericArguments().[0]
let converter = AsyncApiActionInvoker.GetResultConverter(innerReturnType, actionDescriptor)
this.GetType()
.GetMethod("StartAsTask", BindingFlags.NonPublic ||| BindingFlags.Static)
.MakeGenericMethod(innerReturnType)
.Invoke(null, [| computation; converter; controllerContext; cancellationToken |])
|> unbox
else base.InvokeActionAsync(actionContext, cancellationToken)
我希望这对其他人有帮助!
作为选项(浏览器编译的代码,可能包含错误)
let (|Async|_|) (ty: Type) =
if ty.IsGenericType && ty.GetGenericTypeDefinition() = typedefof<Async<_>> then
Some (ty.GetGenericArguments().[0])
else
None
type AsyncApiActionInvoker() =
inherit Controllers.ApiControllerActionInvoker()
static let AsTaskMethod = typeof<AsyncApiActionInvoker>.GetMethod("AsTask")
static member AsTask<'T> (actionContext: Controllers.HttpActionContext, cancellationToken: CancellationToken) =
let action = async {
let task =
actionContext.ActionDescriptor.ExecuteAsync(
actionContext.ControllerContext,
actionContext.ActionArguments,
cancellationToken
)
let! result = Async.AwaitTask task
let! asyncResult = result :?> Async<'T>
return actionContext.ActionDescriptor.ResultConverter.Convert(actionContext.ControllerContext, box asyncResult)
}
Async.StartAsTask(action, cancellationToken = cancellationToken)
override x.InvokeActionAsync(actionContext, cancellationToken) =
if actionContext = null then
raise <| ArgumentNullException("actionContext")
match actionContext.ActionDescriptor.ReturnType with
| Async resultType ->
let specialized = AsTaskMethod.MakeGenericMethod(resultType)
downcast specialized.Invoke(null, [|actionContext, cancellationToken|])
| _ -> base.InvokeActionAsync(actionContext, cancellationToken)
我目前正在尝试创建一个 IHttpActionInvoker
用于 ASP.NET Web API,这将使结果成为 Async<'T>
。目前,我忽略 IHttpActionResult
的转换,只关心 HttpResponseMessage
和 'T
类型的值。我目前有以下实现:
type AsyncApiActionInvoker() =
inherit Controllers.ApiControllerActionInvoker()
override x.InvokeActionAsync(actionContext, cancellationToken) =
if actionContext = null then
raise <| ArgumentNullException("actionContext")
let actionDescriptor = actionContext.ActionDescriptor
Contract.Assert(actionDescriptor <> null)
if actionDescriptor.ReturnType = typeof<Async<HttpResponseMessage>> then
let controllerContext = actionContext.ControllerContext
Contract.Assert(controllerContext <> null)
let task = async {
let! asyncResult = Async.AwaitTask <| actionDescriptor.ExecuteAsync(controllerContext, actionContext.ActionArguments, cancellationToken)
// For now, throw if the result is an IHttpActionResult.
if typeof<IHttpActionResult>.IsAssignableFrom(actionDescriptor.ReturnType) then
raise <| InvalidOperationException("IHttpResult is not supported when returning an Async")
let! result = asyncResult :?> Async<HttpResponseMessage>
return actionDescriptor.ResultConverter.Convert(controllerContext, result) }
Async.StartAsTask(task, cancellationToken = cancellationToken)
else base.InvokeActionAsync(actionContext, cancellationToken)
这仅适用于 Async<HttpResponseMessage>
。如果我尝试转换为 Async<_>
,我会收到一个异常,指出我无法转换为 Async<obj>
。我也无法正确检测 actionDescriptor.ReturnType
是否为 Async<_>
。这并不让我吃惊,但我不确定如何解决这个问题。
在从 Whosebug 外部获得一些有用的提示后,我想出了以下似乎有效的解决方案。我对此并不感到兴奋,但它确实起作用了。如果有任何提示或指示,我将不胜感激:
type AsyncApiActionInvoker() =
inherit Controllers.ApiControllerActionInvoker()
static member internal GetResultConverter(instanceType: Type, actionDescriptor: HttpActionDescriptor) : IActionResultConverter =
if instanceType <> null && instanceType.IsGenericParameter then
raise <| InvalidOperationException()
if instanceType = null || typeof<HttpResponseMessage>.IsAssignableFrom instanceType then
actionDescriptor.ResultConverter
else
let valueConverterType = typedefof<ValueResultConverter<_>>.MakeGenericType instanceType
let newInstanceExpression = Expression.New valueConverterType
let ctor = Expression.Lambda<Func<IActionResultConverter>>(newInstanceExpression).Compile()
ctor.Invoke()
static member internal StartAsTask<'T>(task, resultConverter: IActionResultConverter, controllerContext, cancellationToken) =
let computation = async {
let! comp = Async.AwaitTask task
let! (value: 'T) = unbox comp
return resultConverter.Convert(controllerContext, value) }
Async.StartAsTask(computation, cancellationToken = cancellationToken)
override this.InvokeActionAsync(actionContext, cancellationToken) =
if actionContext = null then
raise <| ArgumentNullException("actionContext")
let actionDescriptor = actionContext.ActionDescriptor
Contract.Assert(actionDescriptor <> null)
let returnType = actionDescriptor.ReturnType
// For now, throw if the result is an IHttpActionResult.
if typeof<IHttpActionResult>.IsAssignableFrom(returnType) then
raise <| InvalidOperationException("IHttpResult is not supported when returning an Async")
if returnType.IsGenericType && returnType.GetGenericTypeDefinition() = typedefof<Async<_>> then
let controllerContext = actionContext.ControllerContext
Contract.Assert(controllerContext <> null)
let computation = actionDescriptor.ExecuteAsync(controllerContext, actionContext.ActionArguments, cancellationToken)
let innerReturnType = returnType.GetGenericArguments().[0]
let converter = AsyncApiActionInvoker.GetResultConverter(innerReturnType, actionDescriptor)
this.GetType()
.GetMethod("StartAsTask", BindingFlags.NonPublic ||| BindingFlags.Static)
.MakeGenericMethod(innerReturnType)
.Invoke(null, [| computation; converter; controllerContext; cancellationToken |])
|> unbox
else base.InvokeActionAsync(actionContext, cancellationToken)
我希望这对其他人有帮助!
作为选项(浏览器编译的代码,可能包含错误)
let (|Async|_|) (ty: Type) =
if ty.IsGenericType && ty.GetGenericTypeDefinition() = typedefof<Async<_>> then
Some (ty.GetGenericArguments().[0])
else
None
type AsyncApiActionInvoker() =
inherit Controllers.ApiControllerActionInvoker()
static let AsTaskMethod = typeof<AsyncApiActionInvoker>.GetMethod("AsTask")
static member AsTask<'T> (actionContext: Controllers.HttpActionContext, cancellationToken: CancellationToken) =
let action = async {
let task =
actionContext.ActionDescriptor.ExecuteAsync(
actionContext.ControllerContext,
actionContext.ActionArguments,
cancellationToken
)
let! result = Async.AwaitTask task
let! asyncResult = result :?> Async<'T>
return actionContext.ActionDescriptor.ResultConverter.Convert(actionContext.ControllerContext, box asyncResult)
}
Async.StartAsTask(action, cancellationToken = cancellationToken)
override x.InvokeActionAsync(actionContext, cancellationToken) =
if actionContext = null then
raise <| ArgumentNullException("actionContext")
match actionContext.ActionDescriptor.ReturnType with
| Async resultType ->
let specialized = AsTaskMethod.MakeGenericMethod(resultType)
downcast specialized.Invoke(null, [|actionContext, cancellationToken|])
| _ -> base.InvokeActionAsync(actionContext, cancellationToken)