code: public void close() {
          // clean up collections
          if (consumers != null) {
              consumers.clear();
              consumers = null;
          }
          if (providers != null) {
              providers.clear();
              providers = null;
          }
          if (listeners != null) {
              listeners.clear();
              listeners = null;
          }
      }
docs: Close the pipe