black format
This commit is contained in:
parent
1d54e2232f
commit
c66fe37eb4
@ -340,7 +340,9 @@ def make_pop_server_callback(mails_path: Path, users: list[User], timeout_second
|
|||||||
async def session_cb(reader: StreamReader, writer: StreamWriter):
|
async def session_cb(reader: StreamReader, writer: StreamWriter):
|
||||||
c_shared_state.set(s_state)
|
c_shared_state.set(s_state)
|
||||||
ip, _ = writer.get_extra_info("peername")
|
ip, _ = writer.get_extra_info("peername")
|
||||||
c_state.set(State(reader=reader, writer=writer, ip=ip, req_id=s_state.next_id()))
|
c_state.set(
|
||||||
|
State(reader=reader, writer=writer, ip=ip, req_id=s_state.next_id())
|
||||||
|
)
|
||||||
logger.info("Got pop server callback")
|
logger.info("Got pop server callback")
|
||||||
try:
|
try:
|
||||||
try:
|
try:
|
||||||
|
@ -20,7 +20,12 @@ logger = logging.getLogger("smtp")
|
|||||||
|
|
||||||
|
|
||||||
class MyHandler(AsyncMessage):
|
class MyHandler(AsyncMessage):
|
||||||
def __init__(self, mails_path: Path, mbox_finder: Callable[[str], list[str]], listener_type: str):
|
def __init__(
|
||||||
|
self,
|
||||||
|
mails_path: Path,
|
||||||
|
mbox_finder: Callable[[str], list[str]],
|
||||||
|
listener_type: str,
|
||||||
|
):
|
||||||
super().__init__()
|
super().__init__()
|
||||||
self.mails_path = mails_path
|
self.mails_path = mails_path
|
||||||
self.mbox_finder = mbox_finder
|
self.mbox_finder = mbox_finder
|
||||||
|
Loading…
Reference in New Issue
Block a user