docs: @Override
      public boolean close() {
          this.open = false;
  
          for (int i = 0; i < listeningStreams.get(); i++) {
             try{
                this.queue.offer((T) POISON_PILL);
             }catch(Exception e){
  
             }
  
          }
  
          return true;
      }