net_transport.go
func (n *netPipeline) Close() error {
	n.shutdownLock.Lock()
	defer n.shutdownLock.Unlock()
	if n.shutdown {
		return nil
	}

	// Release the connection
	n.conn.Release()

	n.shutdown = true
	close(n.shutdownCh)
	return nil
}
func (n *netPipeline) Close() error {
	n.shutdownLock.Lock()
	defer n.shutdownLock.Unlock()
	if n.shutdown {
		return nil
	}

	// Release the connection
	n.conn.Release()

	n.shutdown = true
	close(n.shutdownCh)
	return nil
}
func ( n * netPipeline ) Close ( ) error { n . shutdownLock . Lock ( ) defer n . shutdownLock . Unlock ( ) if n . shutdown { return nil } // Release the connection n . conn . Release ( ) n . shutdown = true close ( n . shutdownCh ) return nil }
// Closed is used to shutdown the pipeline connection.
Closed is used to shutdown the pipeline connection .