mirror of
https://github.com/romanz/amodem.git
synced 2026-04-20 21:26:39 +08:00
async: rename to async_reader
async is becoming a reserved word in Python 3.7
This commit is contained in:
@@ -8,7 +8,7 @@ import zlib
|
|||||||
|
|
||||||
import pkg_resources
|
import pkg_resources
|
||||||
|
|
||||||
from . import async
|
from . import async_reader
|
||||||
from . import audio
|
from . import audio
|
||||||
from . import calib
|
from . import calib
|
||||||
from . import main
|
from . import main
|
||||||
@@ -77,7 +77,7 @@ def FileType(mode, interface_factory=None):
|
|||||||
assert audio_interface is not None
|
assert audio_interface is not None
|
||||||
if 'r' in mode:
|
if 'r' in mode:
|
||||||
s = audio_interface.recorder()
|
s = audio_interface.recorder()
|
||||||
return async.AsyncReader(stream=s, bufsize=s.bufsize)
|
return async_reader.AsyncReader(stream=s, bufsize=s.bufsize)
|
||||||
if 'w' in mode:
|
if 'w' in mode:
|
||||||
return audio_interface.player()
|
return audio_interface.player()
|
||||||
|
|
||||||
|
|||||||
@@ -1,7 +1,7 @@
|
|||||||
import mock
|
import mock
|
||||||
import time
|
import time
|
||||||
import pytest
|
import pytest
|
||||||
from amodem import async
|
from amodem import async_reader
|
||||||
import logging
|
import logging
|
||||||
|
|
||||||
logging.basicConfig(format='%(message)s')
|
logging.basicConfig(format='%(message)s')
|
||||||
@@ -13,7 +13,7 @@ def test_async_reader():
|
|||||||
return b'\x00' * n
|
return b'\x00' * n
|
||||||
s = mock.Mock()
|
s = mock.Mock()
|
||||||
s.read = _read
|
s.read = _read
|
||||||
r = async.AsyncReader(s, 1)
|
r = async_reader.AsyncReader(s, 1)
|
||||||
|
|
||||||
n = 5
|
n = 5
|
||||||
assert r.read(n) == b'\x00' * n
|
assert r.read(n) == b'\x00' * n
|
||||||
@@ -25,6 +25,6 @@ def test_async_reader():
|
|||||||
def test_async_reader_error():
|
def test_async_reader_error():
|
||||||
s = mock.Mock()
|
s = mock.Mock()
|
||||||
s.read.side_effect = IOError()
|
s.read.side_effect = IOError()
|
||||||
r = async.AsyncReader(s, 1)
|
r = async_reader.AsyncReader(s, 1)
|
||||||
with pytest.raises(IOError):
|
with pytest.raises(IOError):
|
||||||
r.read(3)
|
r.read(3)
|
||||||
Reference in New Issue
Block a user