(self, maxlen)
| 3981 | self.ws.send(data, websocket.ABNF.OPCODE_BINARY) |
| 3982 | |
| 3983 | def recv(self, maxlen): |
| 3984 | while len(self.recvbuf) < maxlen: |
| 3985 | self.recvbuf += self.ws.recv() |
| 3986 | |
| 3987 | ret = self.recvbuf[:maxlen] |
| 3988 | self.recvbuf = self.recvbuf[maxlen:] |
| 3989 | return ret |
| 3990 | |
| 3991 | ws = BinWebSocket('localhost', ws_port) |
| 3992 | lconn = wire.LightningConnection(ws, |