(conn)
| 677 | """ |
| 678 | |
| 679 | def create_on_message(conn): |
| 680 | def _fsend(data): |
| 681 | data = bytes(data) |
| 682 | conn.write_message(data, binary=True) |
| 683 | return len(data) |
| 684 | |
| 685 | on_message = _ffi_api.CreateEventDrivenServer(_fsend, "WebSocketProxyServer", "%toinit") |
| 686 | return on_message |
| 687 | |
| 688 | @gen.coroutine |
| 689 | def _connect(key): |
no outgoing calls
no test coverage detected
searching dependent graphs…