class ConcurrentStreamSummary implements ITopK<T> {

    @Override
    public boolean add(final T element) {
        return add(element, 1);
    }

    public  ConcurrentStreamSummary(final int capacity);

}