From cb3a59e0acb726faf4c2db9c23496ac519ad5432 Mon Sep 17 00:00:00 2001
From: Chih Cheng Liang <chihchengliang@gmail.com>
Date: Mon, 5 Aug 2019 17:02:18 +0800
Subject: [PATCH] ttl as int

---
 libp2p/stream_muxer/abc.py                |  2 +-
 libp2p/stream_muxer/mplex/mplex_stream.py | 10 +++++-----
 2 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/libp2p/stream_muxer/abc.py b/libp2p/stream_muxer/abc.py
index 05a4cfe8..0b779336 100644
--- a/libp2p/stream_muxer/abc.py
+++ b/libp2p/stream_muxer/abc.py
@@ -112,7 +112,7 @@ class IMuxedStream(ABC):
         """
 
     @abstractmethod
-    def set_deadline(self, ttl: float) -> bool:
+    def set_deadline(self, ttl: int) -> bool:
         """
         set deadline for muxed stream
         :return: a new stream
diff --git a/libp2p/stream_muxer/mplex/mplex_stream.py b/libp2p/stream_muxer/mplex/mplex_stream.py
index e4fb21d0..e4627ec5 100644
--- a/libp2p/stream_muxer/mplex/mplex_stream.py
+++ b/libp2p/stream_muxer/mplex/mplex_stream.py
@@ -13,8 +13,8 @@ class MplexStream(IMuxedStream):
     stream_id: int
     initiator: bool
     mplex_conn: IMuxedConn
-    read_deadline: float
-    write_deadline: float
+    read_deadline: int
+    write_deadline: int
     local_closed: bool
     remote_closed: bool
     stream_lock: asyncio.Lock
@@ -103,7 +103,7 @@ class MplexStream(IMuxedStream):
         return True
 
     # TODO deadline not in use
-    def set_deadline(self, ttl: float) -> bool:
+    def set_deadline(self, ttl: int) -> bool:
         """
         set deadline for muxed stream
         :return: True if successful
@@ -112,7 +112,7 @@ class MplexStream(IMuxedStream):
         self.write_deadline = ttl
         return True
 
-    def set_read_deadline(self, ttl: float) -> bool:
+    def set_read_deadline(self, ttl: int) -> bool:
         """
         set read deadline for muxed stream
         :return: True if successful
@@ -120,7 +120,7 @@ class MplexStream(IMuxedStream):
         self.read_deadline = ttl
         return True
 
-    def set_write_deadline(self, ttl: float) -> bool:
+    def set_write_deadline(self, ttl: int) -> bool:
         """
         set write deadline for muxed stream
         :return: True if successful