1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24
import asyncio from rtlsdr import RtlSdr RATE_IN = RATE_OUT = 170000 RATE_OUT2 = 32000 CUSTOM_ATAN = 1 DEEMPH = 1 SQUELCH = 0 async def streaming(): sdr = RtlSdr() async for samples in sdr.stream(): # do something with samples # ... # to stop streaming: await sdr.stop() # done sdr.close() loop = asyncio.get_event_loop() loop.run_until_complete(streaming())