jogueber

@AutoService
interface Factory{
 StreamProducer createStreamProducer(Duration timeout,Integer maxMessages);
}
class TimeOutOrConsumedException extends Exception{
  public TimeOutOrConsumedException(String message){
  super(message)
  }
}