amp-async 0.1.2

Implementation of the AMP remoting protocol
Documentation 
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
47
48
49
50
51
52

#!/usr/bin/env python

from twisted.internet.defer import inlineCallbacks, DeferredList
from twisted.internet.endpoints import ProcessEndpoint
from twisted.internet.protocol import Factory
from twisted.protocols import amp

class Sum(amp.Command):
    arguments = [(b'a', amp.Integer()),
                 (b'b', amp.Integer())]
    response = [(b'total', amp.Integer())]

class Responder(amp.AMP):
    def makeConnection(self, transport):
        transport.getPeer = lambda: 'local'
        transport.getHost = lambda: 'host'
        super().makeConnection(transport)

    @Sum.responder
    def do_sum(self, a, b):
        total = a + b
        print(f'Did a sum: {a} + {b} = {total}')
        return {'total': total}
    
RUST_PATH = 'target/release/amp-test'

@inlineCallbacks
def start():
    from twisted.internet import reactor

    ep = ProcessEndpoint(reactor, RUST_PATH, [RUST_PATH], childFDs={0: 'w', 1: 'r', 2: 2}, env=None)
    factory = Factory.forProtocol(Responder)
    rust = yield ep.connect(factory)


    call1 = rust.callRemote(Sum, a=1, b=2)
    call2 = rust.callRemote(Sum, a=4, b=-100)

    dl = yield DeferredList([call1, call2])
    print(dl)

    reactor.stop()

def main():
    from twisted.internet import reactor

    start().addBoth(lambda result: print(f"result: {result!r}"))

    print("Reactor running")
    reactor.run()

main()