core/src/main/java/org/apache/rocketmq/streams/core/topology/real/ProcessorFactory.java [32:42]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        this.supplier = supplier;
    }

    @Override
    public String getName() {
        return name;
    }

    @Override
    public Processor<T> build() {
        return supplier.get();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



core/src/main/java/org/apache/rocketmq/streams/core/topology/real/SourceFactory.java [34:44]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        this.supplier = supplier;
    }

    @Override
    public String getName() {
        return name;
    }

    @Override
    public Processor<T> build() {
        return supplier.get();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -