func (i *InmemTransport) DisconnectAll() {
	i.Lock()
	defer i.Unlock()
	i.peers = make(map[ServerAddress]*InmemTransport)

	// Handle pipelines
	for _, pipeline := range i.pipelines {
		pipeline.Close()
	}
	i.pipelines = nil
}
func (i *InmemTransport) DisconnectAll() {
	i.Lock()
	defer i.Unlock()
	i.peers = make(map[ServerAddress]*InmemTransport)

	
	for _, pipeline := range i.pipelines {
		pipeline.Close()
	}
	i.pipelines = nil
}
func ( i * InmemTransport ) DisconnectAll ( ) { i . Lock ( ) defer i . Unlock ( ) i . peers = make ( map [ ServerAddress ] * InmemTransport ) // Handle pipelines for _ , pipeline := range i . pipelines { pipeline . Close ( ) } i . pipelines = nil }
// DisconnectAll is used to remove all routes to peers.
DisconnectAll is used to remove all routes to peers .