(ds, readable, writable)
| 1166 | ds = resource_sharer.DupSocket(s) |
| 1167 | return rebuild_connection, (ds, conn.readable, conn.writable) |
| 1168 | def rebuild_connection(ds, readable, writable): |
| 1169 | sock = ds.detach() |
| 1170 | return Connection(sock.detach(), readable, writable) |
| 1171 | reduction.register(Connection, reduce_connection) |
| 1172 | |
| 1173 | def reduce_pipe_connection(conn): |
nothing calls this directly
no test coverage detected