blob: e00e92abb611744359661692d865517af5410e72 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
|
//
// Copyright (c) ZeroC, Inc. All rights reserved.
//
import Foundation
import PromiseKit
/// Base protocol for dynamic asynchronous dispatch servants.
public protocol BlobjectAsync {
/// Dispatch an incoming request.
///
/// - parameter inEncaps: `Data` - The encoded in-parameters for the operation.
///
/// - parameter current: `Ice.Current` - The Current object to pass to the operation.
///
/// - returns: `PromiseKit.Promise<(ok: Bool, outParams: Data)>` - The result of the operation.
///
/// - ok: `Bool` - True if the operation completed successfully, false if
/// the operation raised a user exception (in this case, outParams
/// contains the encoded user exception). If the operation raises an
/// Ice run-time exception, it must throw it directly.
///
/// - outParams: `Data` - The encoded out-paramaters and return value
/// for the operation. The return value follows any out-parameters.
func ice_invokeAsync(inEncaps: Data, current: Current) -> Promise<(ok: Bool, outParams: Data)>
}
/// Request dispatcher for BlobjectAsync servants.
public struct BlobjectAsyncDisp: Disp {
public let servant: BlobjectAsync
public init(_ servant: BlobjectAsync) {
self.servant = servant
}
public func dispatch(request: Request, current: Current) throws {
let inEncaps = try request.readParamEncaps()
firstly {
self.servant.ice_invokeAsync(inEncaps: inEncaps, current: current)
}.done(on: nil) { invokeResult in
request.writeParamEncaps(ok: invokeResult.ok, outParams: invokeResult.outParams)
}.catch(on: nil) { err in
request.exception(err)
}
}
}
|
