--- a/mercurial/wireprotoframing.py Mon Feb 21 13:03:43 2022 -0700
+++ b/mercurial/wireprotoframing.py Mon Feb 21 13:08:28 2022 -0700
@@ -134,7 +134,7 @@
@attr.s(slots=True)
-class frameheader(object):
+class frameheader:
"""Represents the data in a frame header."""
length = attr.ib()
@@ -146,7 +146,7 @@
@attr.s(slots=True, repr=False)
-class frame(object):
+class frame:
"""Represents a parsed frame."""
requestid = attr.ib()
@@ -589,7 +589,7 @@
)
-class bufferingcommandresponseemitter(object):
+class bufferingcommandresponseemitter:
"""Helper object to emit command response frames intelligently.
Raw command response data is likely emitted in chunks much smaller
@@ -699,7 +699,7 @@
# mechanism.
-class identityencoder(object):
+class identityencoder:
"""Encoder for the "identity" stream encoding profile."""
def __init__(self, ui):
@@ -715,7 +715,7 @@
return b''
-class identitydecoder(object):
+class identitydecoder:
"""Decoder for the "identity" stream encoding profile."""
def __init__(self, ui, extraobjs):
@@ -728,7 +728,7 @@
return data
-class zlibencoder(object):
+class zlibencoder:
def __init__(self, ui):
import zlib
@@ -749,7 +749,7 @@
return res
-class zlibdecoder(object):
+class zlibdecoder:
def __init__(self, ui, extraobjs):
import zlib
@@ -764,7 +764,7 @@
return self._decompressor.decompress(data)
-class zstdbaseencoder(object):
+class zstdbaseencoder:
def __init__(self, level):
from . import zstd
@@ -792,7 +792,7 @@
super(zstd8mbencoder, self).__init__(3)
-class zstdbasedecoder(object):
+class zstdbasedecoder:
def __init__(self, maxwindowsize):
from . import zstd
@@ -842,7 +842,7 @@
STREAM_ENCODERS_ORDER.append(b'identity')
-class stream(object):
+class stream:
"""Represents a logical unidirectional series of frames."""
def __init__(self, streamid, active=False):
@@ -995,7 +995,7 @@
}
-class serverreactor(object):
+class serverreactor:
"""Holds state of a server handling frame-based protocol requests.
This class is the "brain" of the unified frame-based protocol server
@@ -1683,7 +1683,7 @@
return self._makeerrorresult(_(b'server already errored'))
-class commandrequest(object):
+class commandrequest:
"""Represents a request to run a command."""
def __init__(self, requestid, name, args, datafh=None, redirect=None):
@@ -1695,7 +1695,7 @@
self.state = b'pending'
-class clientreactor(object):
+class clientreactor:
"""Holds state of a client issuing frame-based protocol requests.
This is like ``serverreactor`` but for client-side state.