class StreamFilter implements Predicate<Stream> {

  @Override
  public boolean test(Stream stream) {
    return matchesStreamKey(stream.getKey(), keyQuery)
        && matchesSchemaKey(stream.getSchemaKey(), schemaKeyQuery)
        && matchesSpecification(stream.getSpecification(), specQuery);
  }

  public  StreamFilter(StreamKeyQuery keyQuery, SpecificationQuery specQuery, SchemaKeyQuery schemaKeyQuery);

}