T
- typepublic abstract class AbstractRxStage<T> extends Object implements RxStage<T>
RxStage
that implements metering.Constructor and Description |
---|
AbstractRxStage(String stageName)
Constructs an abstact rxstage.
|
Modifier and Type | Method and Description |
---|---|
Meter |
getInMeter()
Gets the input meter of this stage.
|
Meter |
getOutMeter()
Gets the output meter of this stage.
|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
onCompleted, onError, onNext
close
public AbstractRxStage(String stageName)
stageName
- the stage namepublic Meter getInMeter()
public Meter getOutMeter()
Copyright © 2017 The Apache Software Foundation. All rights reserved.