(ds, readable, writable)
| 1212 | ds = resource_sharer.DupSocket(s) |
| 1213 | return rebuild_connection, (ds, conn.readable, conn.writable) |
| 1214 | def rebuild_connection(ds, readable, writable): |
| 1215 | sock = ds.detach() |
| 1216 | return Connection(sock.detach(), readable, writable) |
| 1217 | reduction.register(Connection, reduce_connection) |
| 1218 | |
| 1219 | def reduce_pipe_connection(conn): |
nothing calls this directly
no test coverage detected
searching dependent graphs…