fixed super and multi_addr variable name
This commit is contained in:
parent
f32b0cc3ef
commit
51921fe728
|
@ -3,12 +3,13 @@ import asyncio
|
||||||
|
|
||||||
class Stream(IStream):
|
class Stream(IStream):
|
||||||
|
|
||||||
def __init__(self, peer_id, maddr):
|
def __init__(self, peer_id, multi_addr):
|
||||||
|
IStream.__init__(self, peer_id, multi_addr)
|
||||||
self.peer_id = peer_id
|
self.peer_id = peer_id
|
||||||
|
|
||||||
ip = maddr.get_protocol_value("ip4")
|
ip = multi_addr.get_protocol_value("ip4")
|
||||||
port = maddr.get_protocol_value("tcp")
|
port = multi_addr.get_protocol_value("tcp")
|
||||||
|
|
||||||
self.open_connection(ip, port)
|
self.open_connection(ip, port)
|
||||||
|
|
||||||
async def open_connection(self, ip, port):
|
async def open_connection(self, ip, port):
|
||||||
|
|
|
@ -2,9 +2,9 @@ from abc import ABC, abstractmethod
|
||||||
|
|
||||||
class IStream(ABC):
|
class IStream(ABC):
|
||||||
|
|
||||||
def __init__(self, peer_id, maddr):
|
def __init__(self, peer_id, multi_addr):
|
||||||
self.peer_id = peer_id
|
self.peer_id = peer_id
|
||||||
self.maddr = maddr
|
self.multi_addr = multi_addr
|
||||||
|
|
||||||
@abstractmethod
|
@abstractmethod
|
||||||
def protocol(self):
|
def protocol(self):
|
||||||
|
|
Loading…
Reference in New Issue
Block a user