public void shutdown() {
    synchronized (omap) {
      for (Map.Entry<TapStream, TapConnectionProvider> me : omap.entrySet()) {
        me.getValue().shutdown();
      }
    }
  }
Shuts down all tap streams that are currently running.
src/main/java/net/spy/memcached/TapClient.java