Loading sjrpc/core/protocols/tunnel.py +5 −0 Original line number Diff line number Diff line Loading @@ -25,6 +25,7 @@ class TunnelProtocol(Protocol): self._endpoint, self._socket = socket.socketpair() else: self._endpoint = endpoint self._socket = None self._from_tun_to_endpoint_buf = '' self._asked = 0 # Data asked to the peer Loading Loading @@ -83,6 +84,10 @@ class TunnelProtocol(Protocol): # Public methods: # @property def socket(self): return self._socket def end_of_message(self): ''' Handle inbound data from the :class:`RpcConnection` peer and place it Loading Loading
sjrpc/core/protocols/tunnel.py +5 −0 Original line number Diff line number Diff line Loading @@ -25,6 +25,7 @@ class TunnelProtocol(Protocol): self._endpoint, self._socket = socket.socketpair() else: self._endpoint = endpoint self._socket = None self._from_tun_to_endpoint_buf = '' self._asked = 0 # Data asked to the peer Loading Loading @@ -83,6 +84,10 @@ class TunnelProtocol(Protocol): # Public methods: # @property def socket(self): return self._socket def end_of_message(self): ''' Handle inbound data from the :class:`RpcConnection` peer and place it Loading