rcomp-api/src/main/java/component/api/RComponent.java

package component.api;

import org.reactivestreams.Publisher;
import org.reactivestreams.Subscriber;

public interface RComponent {
    <T> Publisher<T> from(String destination, Class<T> type);
    <T> Subscriber<T> to(String destination, Class<T> type);
}