@@ -395,7 +395,7 @@ def username_pw_set(self, username: str, password: Optional[str] = None) -> None
395
395
if password is not None :
396
396
self ._password = password
397
397
398
- def connect (
398
+ def connect ( # noqa: PLR0913, too many arguments in function definition
399
399
self ,
400
400
clean_session : bool = True ,
401
401
host : Optional [str ] = None ,
@@ -466,22 +466,7 @@ def connect(
466
466
raise MMQTTException (exc_msg ) from last_exception
467
467
raise MMQTTException (exc_msg )
468
468
469
- def _send_bytes (
470
- self ,
471
- buffer : Union [bytes , bytearray , memoryview ],
472
- ):
473
- bytes_sent : int = 0
474
- bytes_to_send = len (buffer )
475
- view = memoryview (buffer )
476
- while bytes_sent < bytes_to_send :
477
- try :
478
- bytes_sent += self ._sock .send (view [bytes_sent :])
479
- except OSError as exc :
480
- if exc .errno == EAGAIN :
481
- continue
482
- raise
483
-
484
- def _connect ( # noqa: PLR0912, PLR0915, Too many branches, Too many statements
469
+ def _connect ( # noqa: PLR0912, PLR0913, PLR0915, Too many branches, Too many arguments, Too many statements
485
470
self ,
486
471
clean_session : bool = True ,
487
472
host : Optional [str ] = None ,
0 commit comments