Lines Matching full:await
125 x = await c.read_value(None)
127 await c.write_value(None, bytes([122]))
175 await client.power_on()
176 await server.power_on()
177 connection = await client.connect(server.random_address)
180 await peer.discover_services()
181 await peer.discover_characteristics()
187 v = await cp.read_value()
189 await cp.write_value(124)
190 await async_barrier()
193 v = await cp.read_value()
195 await cp.write_value(125, with_response=True)
196 await async_barrier()
200 await cd.write_value(100, with_response=True)
201 await async_barrier()
208 cd2v = await cd2.read_value()
217 await c.subscribe(on_change)
218 await server.notify_subscribers(characteristic)
219 await async_barrier()
223 await server.notify_subscribers(characteristic, value=bytes([125]))
224 await async_barrier()
228 await c.unsubscribe(on_change)
229 await server.notify_subscribers(characteristic)
230 await async_barrier()
233 await cp.subscribe(on_change)
234 await server.notify_subscribers(characteristic)
235 await async_barrier()
239 await server.notify_subscribers(characteristic, value=bytes([126]))
240 await async_barrier()
244 await cp.unsubscribe(on_change)
245 await server.notify_subscribers(characteristic)
246 await async_barrier()
250 await cd.subscribe(on_change)
251 await server.notify_subscribers(characteristic)
252 await async_barrier()
256 await cd.unsubscribe(on_change)
257 await server.notify_subscribers(characteristic)
258 await async_barrier()
324 value = await a.read_value(None)
328 await a.write_value(None, v)
336 value = await a.read_value(None)
340 await a.write_value(None, v)
349 value = await a.read_value(None)
352 await a.write_value(None, pv)
362 value = await a.read_value(None)
365 await a.write_value(None, pv)
376 value = await a.read_value(None)
379 await a.write_value(None, pv)
388 value = await a.read_value(None)
391 await a.write_value(None, ev)
404 x = await c.read(None)
423 x = await c.read(None)
429 await c.write(z, b)
498 await client.power_on()
499 await server.power_on()
500 connection = await client.connect(server.random_address)
503 await peer.discover_services()
504 await peer.discover_characteristics()
512 v1 = await peer.read_value(c1)
515 await peer.write_value(c1, b)
516 await async_barrier()
518 v1 = await peer.read_value(c1)
528 v1 = await peer.read_value(c1)
531 await peer.write_value(c2, b)
532 await async_barrier()
557 await client.power_on()
558 await server.power_on()
559 connection = await client.connect(server.random_address)
562 await peer.discover_services()
566 await s.discover_characteristics()
571 v1 = await c1.read_value()
575 v1 = await a1.read_value()
579 await a1.write_value(struct.unpack('>I', b)[0])
580 await async_barrier()
582 v1 = await a1.read_value()
659 await client.power_on()
660 await server.power_on()
661 connection = await client.connect(server.random_address)
664 await peer.discover_services()
665 await peer.discover_characteristics()
684 await peer.subscribe(c1)
685 await async_barrier()
691 await server.indicate_subscribers(characteristic1)
692 await async_barrier()
694 await server.notify_subscribers(characteristic1)
695 await async_barrier()
702 await server.notify_subscribers(characteristic1, bytes([0, 1, 2]))
703 await async_barrier()
709 await peer.unsubscribe(c1)
710 await server.notify_subscribers(characteristic1)
720 await peer.subscribe(c2, on_c2_update)
721 await async_barrier()
722 await server.notify_subscriber(
725 await async_barrier()
727 await server.indicate_subscriber(
730 await async_barrier()
735 await peer.unsubscribe(c2, on_c2_update)
736 await server.indicate_subscriber(
739 await async_barrier()
762 await peer.subscribe(c3, on_c3_update_2)
763 await async_barrier()
764 await server.notify_subscriber(
767 await async_barrier()
777 await peer.unsubscribe(c3)
778 await peer.subscribe(c3, on_c3_update_3, prefer_notify=False)
779 await async_barrier()
781 await server.indicate_subscriber(
784 await async_barrier()
794 await peer.unsubscribe(c3)
795 await server.notify_subscriber(
798 await server.indicate_subscriber(
801 await async_barrier()
836 await client.power_on()
837 await server.power_on()
838 connection = await client.connect(server.random_address)
841 await peer.discover_services()
842 await peer.discover_characteristics()
850 await c1.subscribe()
851 await async_barrier()
854 await c2.subscribe()
855 await async_barrier()
859 await c1.unsubscribe()
860 await async_barrier()
864 await c2.unsubscribe()
865 await async_barrier()
869 await c1.unsubscribe()
870 await async_barrier()
874 await c2.unsubscribe()
875 await async_barrier()
879 await c1.unsubscribe(force=True)
880 await async_barrier()
913 await client.power_on()
914 await server.power_on()
915 connection = await client.connect(server.random_address)
918 await peer.discover_all()
948 await d1.power_on()
949 await d2.power_on()
950 await d3.power_on()
952 d1_connection = await d1.connect(d3.random_address)
956 d2_connection = await d2.connect(d3.random_address)
963 d1_client_mtu = await d1_peer.request_mtu(220)
967 d2_client_mtu = await d2_peer.request_mtu(50)
1058 await test_read_write()
1059 await test_read_write2()
1060 await test_subscribe_notify()
1061 await test_unsubscribe()
1062 await test_characteristic_encoding()
1063 await test_mtu_exchange()
1064 await test_CharacteristicValue()
1065 await test_CharacteristicValue_async()
1066 await test_CharacteristicAdapter()
1230 await client.power_on()
1231 await server.power_on()
1232 connection = await client.connect(server.random_address)
1235 await peer.discover_services()
1236 await peer.discover_characteristics()
1267 await client.power_on()
1268 await server.power_on()
1269 connection = await client.connect(server.random_address)
1274 await c.write_value(b'', with_response=True)