*/
  fun openStreamCount(): Int = withLock { streams.size }

  fun getStream(id: Int): Http2Stream? = withLock { streams[id] }

  internal fun removeStream(streamId: Int): Http2Stream? {
    withLock {
      val stream = streams.remove(streamId)

      // The removed stream may be blocked on a connection-wide window update.
      notifyAll()

        when(addedStream.getFileName()).thenReturn("file.txt:stream");

        FileNotifyInformation removedStream = mock(FileNotifyInformation.class);
        when(removedStream.getAction()).thenReturn(FileNotifyInformation.FILE_ACTION_REMOVED_STREAM);
        when(removedStream.getFileName()).thenReturn("file.txt:removedstream");

        FileNotifyInformation modifiedStream = mock(FileNotifyInformation.class);