forked from capnproto/go-capnp
-
Notifications
You must be signed in to change notification settings - Fork 0
/
localpromise.go
37 lines (32 loc) · 929 Bytes
/
localpromise.go
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
package capnp
// ClientHook for a promise that will be resolved to some other capability
// at some point. Buffers calls in a queue until the promsie is fulfilled,
// then forwards them.
type localPromise struct {
aq *AnswerQueue
}
// NewLocalPromise returns a client that will eventually resolve to a capability,
// supplied via the resolver.
func NewLocalPromise[C ~ClientKind]() (C, Resolver[C]) {
aq := NewAnswerQueue(Method{})
f := NewPromise(Method{}, aq, aq)
p := f.Answer().Client().AddRef()
return C(p), localResolver[C]{
p: f,
}
}
type localResolver[C ~ClientKind] struct {
p *Promise
}
func (lf localResolver[C]) Fulfill(c C) {
msg, seg := NewSingleSegmentMessage(nil)
capID := msg.CapTable().Add(Client(c))
iface := NewInterface(seg, capID)
lf.p.Fulfill(iface.ToPtr())
lf.p.ReleaseClients()
msg.Release()
}
func (lf localResolver[C]) Reject(err error) {
lf.p.Reject(err)
lf.p.ReleaseClients()
}