*/
  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()

      }
      this.errorCode = errorCode
      this.errorException = errorException
      notifyAll()
      if (source.finished && sink.finished) {
        return false
      }
    }
    connection.removeStream(id)
    return true
  }

  @Throws(IOException::class)
  fun receiveData(
    source: BufferedSource,
    length: Int,
  ) {
    assertLockNotHeld()

        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);