Bulk delete from Scala triggering "LEAK: ByteBuf.release() was not called..."

Java SDK
3

Awesome; thank you for the assist!

Working solution with no leak (using 2.2.4)…

  private def purgeDocuments(documents: List[JsonDocument]): Unit = {
    Observable
      .from(documents.map(_.id))
      .flatMap(id => {
        toScalaObservable(CouchbaseConnection.bucket.async.remove(id, PersistTo.MASTER))

      })
      .subscribe
  }