@Test public void testAggregateReceivedBytes() throws Exception { assertThat(metrics.getReceivedBytesCount(), is(6000L)); }
@Override public long getReceivedBytesCount() { long bytesReceived = 0; for (ConnectionMetrics metrics : metricsSet) { bytesReceived += metrics.getReceivedBytesCount(); } return bytesReceived; }
AggregateConnectionMetrics implements ConnectionMetrics { @Override public long getReceivedBytesCount() { long bytesReceived = 0; for (ConnectionMetrics metrics : metricsSet) { bytesReceived += metrics.getReceivedBytesCount(); } return bytesReceived; } }
AggregateConnectionMetrics implements ConnectionMetrics { @Override public long getReceivedBytesCount() { long bytesReceived = 0; for (ConnectionMetrics metrics : metricsSet) { bytesReceived += metrics.getReceivedBytesCount(); } return bytesReceived; }  }
AggregateConnectionMetrics implements ConnectionMetrics { @Override public long getReceivedBytesCount() { long bytesReceived = 0; for (ConnectionMetrics metrics : metricsSet) { bytesReceived += metrics.getReceivedBytesCount(); } return bytesReceived; }  boolean add(ConnectionMetrics connectionMetrics); boolean remove(ConnectionMetrics connectionMetrics); boolean addAll(Collection<? extends ConnectionMetrics> c); boolean removeAll(Collection<?> c); boolean contains(ConnectionMetrics connectionMetrics); boolean isEmpty(); void clear(); @Override long getRequestCount(); @Override long getResponseCount(); @Override long getSentBytesCount(); @Override long getReceivedBytesCount(); @Override void reset(); @Override long getMinBytesPerRequest(); @Override long getMaxBytesPerRequest(); @Override long getMeanBytesPerRequest(); @Override long getMinBytesPerResponse(); @Override long getMaxBytesPerResponse(); @Override long getMeanBytesPerResponse(); @Override long getMinElapsedMilliseconds(); @Override long getMaxElapsedMilliseconds(); @Override long getMeanElapsedMilliseconds(); @Override long getMinSendThroughputBitsPerSecond(); @Override long getMaxSendThroughputBitsPerSecond(); @Override long getMeanSendThroughputBitsPerSecond(); @Override long getMinReceiveThroughputBitsPerSecond(); @Override long getMaxReceiveThroughputBitsPerSecond(); @Override long getMeanReceiveThroughputBitsPerSecond(); }
AggregateConnectionMetrics implements ConnectionMetrics { @Override public long getReceivedBytesCount() { long bytesReceived = 0; for (ConnectionMetrics metrics : metricsSet) { bytesReceived += metrics.getReceivedBytesCount(); } return bytesReceived; }  boolean add(ConnectionMetrics connectionMetrics); boolean remove(ConnectionMetrics connectionMetrics); boolean addAll(Collection<? extends ConnectionMetrics> c); boolean removeAll(Collection<?> c); boolean contains(ConnectionMetrics connectionMetrics); boolean isEmpty(); void clear(); @Override long getRequestCount(); @Override long getResponseCount(); @Override long getSentBytesCount(); @Override long getReceivedBytesCount(); @Override void reset(); @Override long getMinBytesPerRequest(); @Override long getMaxBytesPerRequest(); @Override long getMeanBytesPerRequest(); @Override long getMinBytesPerResponse(); @Override long getMaxBytesPerResponse(); @Override long getMeanBytesPerResponse(); @Override long getMinElapsedMilliseconds(); @Override long getMaxElapsedMilliseconds(); @Override long getMeanElapsedMilliseconds(); @Override long getMinSendThroughputBitsPerSecond(); @Override long getMaxSendThroughputBitsPerSecond(); @Override long getMeanSendThroughputBitsPerSecond(); @Override long getMinReceiveThroughputBitsPerSecond(); @Override long getMaxReceiveThroughputBitsPerSecond(); @Override long getMeanReceiveThroughputBitsPerSecond();  }