Loading sjrpc/core/protocols/tunnel.py +2 −0 Original line number Diff line number Diff line Loading @@ -103,6 +103,8 @@ class TunnelProtocol(Protocol): watcher.stop() def _send_get(self, size): """ Send to the peer, the right to write data on the tunnel. """ self._connection.rpc.send_special('protoctl', label=self._label, type='get', payload=dict(size=size)) self._asked += size Loading Loading
sjrpc/core/protocols/tunnel.py +2 −0 Original line number Diff line number Diff line Loading @@ -103,6 +103,8 @@ class TunnelProtocol(Protocol): watcher.stop() def _send_get(self, size): """ Send to the peer, the right to write data on the tunnel. """ self._connection.rpc.send_special('protoctl', label=self._label, type='get', payload=dict(size=size)) self._asked += size Loading
