code: public void closeStream(H2StreamProcessor p) {
          // only place that should be dealing with the closed stream table,
          // be called by multiple stream objects at the same time, so sync access
          synchronized (streamOpenCloseSync) {
              if (p.getId() != 0) {
                  writeQ.removeNodeFromQ(p.getId());
                  this.closedStreams.add(p);
                  if (p.getId() % 2 == 0) {
                      this.openPushStreams--;
                  } else {
                      decrementActiveClientStreams();
                  }
              }
  
              // Removes all streams that are older than STREAM_CLOSE_DELAY from the streamTable
              long currentTime = System.currentTimeMillis();
              while (closedStreams.peek() != null &&
                     currentTime - closedStreams.peek().getCloseTime() > STREAM_CLOSE_DELAY) {
                  streamTable.remove(closedStreams.remove().getId());
              }
          }
      }
docs: Remove the stream matching the given ID from the write tree, and decrement the number of open streams.
  
  @param int streamID