66import asyncio
77import concurrent
88import logging
9+ import socket
910from datetime import timedelta
1011from fnmatch import fnmatchcase
1112from functools import partial
1213from typing import (
1314 TYPE_CHECKING ,
1415 Any ,
1516 Callable ,
16- Generator ,
1717 Optional ,
1818 Sequence ,
19- Tuple ,
2019 Type ,
2120 Union ,
2221 cast ,
2322 overload ,
2423)
2524
26- import socket
27-
2825from serial_asyncio_fast import create_serial_connection
2926
3027from .parser import (
@@ -394,7 +391,7 @@ def create_rflink_connection(
394391 disconnect_callback : Optional [Callable [[Optional [Exception ]], None ]] = None ,
395392 ignore : Optional [Sequence [str ]] = None ,
396393 loop : Optional [asyncio .AbstractEventLoop ] = None ,
397- ) -> "Coroutine[Any, Any, Tuple [asyncio.BaseTransport, ProtocolBase ]]" :
394+ ) -> "Coroutine[Any, Any, tuple [asyncio.Transport, asyncio.Protocol ]]" :
398395 """Create Rflink manager class, returns transport coroutine."""
399396 ...
400397
@@ -411,7 +408,7 @@ def create_rflink_connection(
411408 disconnect_callback : Optional [Callable [[Optional [Exception ]], None ]] = None ,
412409 ignore : Optional [Sequence [str ]] = None ,
413410 loop : Optional [asyncio .AbstractEventLoop ] = None ,
414- ) -> "Coroutine[Any, Any, Tuple [asyncio.BaseTransport, ProtocolBase ]]" :
411+ ) -> "Coroutine[Any, Any, tuple [asyncio.Transport, asyncio.Protocol ]]" :
415412 """Create Rflink manager class, returns transport coroutine."""
416413 ...
417414
@@ -427,7 +424,7 @@ def create_rflink_connection(
427424 disconnect_callback : Optional [Callable [[Optional [Exception ]], None ]] = None ,
428425 ignore : Optional [Sequence [str ]] = None ,
429426 loop : Optional [asyncio .AbstractEventLoop ] = None ,
430- ) -> "Coroutine[Any, Any, Tuple [asyncio.BaseTransport, ProtocolBase ]]" :
427+ ) -> "Coroutine[Any, Any, tuple [asyncio.Transport, asyncio.Protocol ]]" :
431428 """Create Rflink manager class, returns transport coroutine."""
432429 if loop is None :
433430 loop = asyncio .get_event_loop ()
@@ -442,10 +439,12 @@ def create_rflink_connection(
442439 keepalive = keepalive ,
443440 )
444441
442+ conn : Coroutine [Any , Any , tuple [asyncio .Transport , asyncio .Protocol ]]
443+
445444 # setup serial connection if no transport specified
446445 if host :
447446 conn = loop .create_connection (protocol_factory , host , cast (int , port ))
448447 else :
449- conn = create_serial_connection (loop , protocol_factory , port , baud )
448+ conn = create_serial_connection (loop , protocol_factory , str ( port ) , baud )
450449
451- return conn # type: ignore
450+ return conn
0 commit comments