mirror of
https://github.com/koush/scrypted.git
synced 2026-02-03 14:13:28 +00:00
53 lines
1.2 KiB
Python
53 lines
1.2 KiB
Python
import asyncio
|
|
import rpc
|
|
from rpc_reader import prepare_peer_readloop, RpcFileTransport
|
|
import traceback
|
|
|
|
|
|
class Bar:
|
|
pass
|
|
|
|
|
|
async def main():
|
|
peer, peerReadLoop = await prepare_peer_readloop(loop, RpcFileTransport(4, 3))
|
|
peer.params["foo"] = 3
|
|
jsoncopy = {}
|
|
jsoncopy[rpc.RpcPeer.PROPERTY_JSON_COPY_SERIALIZE_CHILDREN] = True
|
|
jsoncopy["bar"] = Bar()
|
|
peer.params["bar"] = jsoncopy
|
|
|
|
# reader, writer = await asyncio.open_connection(
|
|
# '127.0.0.1', 6666)
|
|
|
|
# writer.write(bytes('abcd', 'utf8'))
|
|
|
|
# async def ticker(delay, to):
|
|
# for i in range(to):
|
|
# # print(i)
|
|
# yield i
|
|
# await asyncio.sleep(delay)
|
|
|
|
# peer.params['ticker'] = ticker(0, 3)
|
|
|
|
print("python starting")
|
|
# await peerReadLoop()
|
|
asyncio.ensure_future(peerReadLoop())
|
|
|
|
# print('getting param')
|
|
test = await peer.getParam("test")
|
|
print(test)
|
|
try:
|
|
i = 0
|
|
async for c in await test():
|
|
print(c)
|
|
if i == 5:
|
|
break
|
|
i = i + 1
|
|
except:
|
|
traceback.print_exc()
|
|
print("all done iterating")
|
|
|
|
|
|
loop = asyncio.new_event_loop()
|
|
loop.run_until_complete(main())
|