Couchbase Java Client

refactor the entire cluster stream connection