mirror of
https://github.com/varun-r-mallya/py-libp2p.git
synced 2026-02-12 16:10:57 +00:00
run ruff format
This commit is contained in:
@ -31,6 +31,7 @@ if TYPE_CHECKING:
|
|||||||
Mplex,
|
Mplex,
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
||||||
class ReadWriteLock:
|
class ReadWriteLock:
|
||||||
def __init__(self):
|
def __init__(self):
|
||||||
self._readers = 0
|
self._readers = 0
|
||||||
@ -55,6 +56,7 @@ class ReadWriteLock:
|
|||||||
def release_write(self):
|
def release_write(self):
|
||||||
self._write_lock.release()
|
self._write_lock.release()
|
||||||
|
|
||||||
|
|
||||||
class MplexStream(IMuxedStream):
|
class MplexStream(IMuxedStream):
|
||||||
"""
|
"""
|
||||||
reference: https://github.com/libp2p/go-mplex/blob/master/stream.go
|
reference: https://github.com/libp2p/go-mplex/blob/master/stream.go
|
||||||
|
|||||||
Reference in New Issue
Block a user